mirror of
https://github.com/simplex-chat/simplexmq.git
synced 2026-04-28 12:45:23 +00:00
Merge branch 'master' into ep/old-sessions-subs
This commit is contained in:
@@ -731,7 +731,7 @@ sendBatch c@ProtocolClient {client_ = PClient {rcvConcurrency, sndQ}} expire b =
|
||||
| n > 0 -> do
|
||||
active <- mkActive_ expire
|
||||
atomically $ writeTBQueue sndQ (active, s)
|
||||
pooledMapConcurrentlyN rcvConcurrency (getResponse c active) rs
|
||||
mapConcurrently (getResponse c active) rs
|
||||
| otherwise -> pure []
|
||||
TBTransmission s r -> do
|
||||
active <- mkActive_ expire
|
||||
|
||||
Reference in New Issue
Block a user