client: removed concurrency limit when waiting for subscription results (#1126)

This commit is contained in:
Evgeny Poberezkin
2024-05-03 22:16:52 +01:00
committed by GitHub
parent 259f6fcc3b
commit b586a6e90a
+1 -1
View File
@@ -718,7 +718,7 @@ sendBatch c@ProtocolClient {client_ = PClient {rcvConcurrency, sndQ}} b = do
| n > 0 -> do
active <- newTVarIO True
atomically $ writeTBQueue sndQ (active, s)
pooledMapConcurrentlyN rcvConcurrency (getResponse c active) rs
mapConcurrently (getResponse c active) rs
| otherwise -> pure []
TBTransmission s r -> do
active <- newTVarIO True