This commit is contained in:
Alexander Bondarenko
2024-05-02 21:21:07 +03:00
parent 4ade06ccfa
commit e804e9542f
+2 -2
View File
@@ -1181,8 +1181,8 @@ subscribeQueues c qs = do
subscribeQueues_ env sessionsUsed smp qs' = do
rs <- sendBatch subscribeSMPQueues smp qs'
let sessId = sessionId $ thParams smp
alive <- atomically $ activeClientSession c (transportSession' smp) sessId
if alive
active <- atomically $ activeClientSession c (transportSession' smp) sessId
if active
then do
atomically $ modifyTVar' sessionsUsed (sessId :)
mapM_ (uncurry $ processSubResult c) rs