dandri/simplexmq
1
0
Fork 0
mirror of https://github.com/simplex-chat/simplexmq.git synced 2026-05-26 01:04:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

reword comment

Browse Source
This commit is contained in:
Alexander Bondarenko
2024-05-30 18:28:39 +03:00
parent 9666339699
commit 12df6fbf4c
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tests/AgentTests/FunctionalAPITests.hs
+1 -1
View File
@@ -1565,7 +1565,7 @@ testBatchedSubscriptions nCreate nDel t =
deleteFail b aIds'
where
agentCfgN :: AgentConfig
agentCfgN = agentCfg {tbqSize = fromIntegral nCreate} -- without reader thread sub notifications would be flushed until all batches finish, blocking on `notifySub`
agentCfgN = agentCfg {tbqSize = fromIntegral nCreate} -- without a reader thread subscriber would block on notifySub when the subQ gets full
subscribe :: AgentClient -> [ConnId] -> ExceptT AgentErrorType IO ()
subscribe c cs = do
r <- subscribeConnections c cs