diff --git a/src/Simplex/Messaging/Agent/Client.hs b/src/Simplex/Messaging/Agent/Client.hs index 4d02a204e..c540c30b2 100644 --- a/src/Simplex/Messaging/Agent/Client.hs +++ b/src/Simplex/Messaging/Agent/Client.hs @@ -404,11 +404,14 @@ closeAgentClient c = liftIO $ do cancelActions $ reconnections c cancelActions $ asyncClients c cancelActions $ smpQueueMsgDeliveries c + cancelActions $ asyncCmdProcesses c atomically . TM2.clear $ activeSubs c atomically . TM2.clear $ pendingSubs c clear subscrConns clear connMsgsQueued clear smpQueueMsgQueues + clear connCmdsQueued + clear asyncCmdQueues clear getMsgLocks where clear :: Monoid m => (AgentClient -> TVar m) -> IO ()