refactor

simplex-chat · Feb 21, 2024 · 0bf8dce · 0bf8dce
1 parent e81d358
commit 0bf8dce
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/Simplex/Messaging/Server.hs b/src/Simplex/Messaging/Server.hs
@@ -404,7 +404,7 @@ clientDisconnected c@Client {clientId, subscriptions, connected, sessionId, endT
     M.foldrWithKey (\sub _ -> M.update deleteCurrentClient sub) cs subs
   asks clients >>= atomically . TM.delete clientId
   tIds <- atomically $ swapTVar endThreads IM.empty
-  forM_ tIds $ \tId -> liftIO $ deRefWeak tId >>= mapM_ killThread
+  liftIO $ mapM_ (mapM_ killThread <=< deRefWeak) tIds
   where
     deleteCurrentClient :: Client -> Maybe Client
     deleteCurrentClient c'