diff --git a/src/Simplex/Messaging/Client.hs b/src/Simplex/Messaging/Client.hs index 6d72e9d1d..3564990c7 100644 --- a/src/Simplex/Messaging/Client.hs +++ b/src/Simplex/Messaging/Client.hs @@ -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