dandri/simplexmq
1
0
Fork 0
mirror of https://github.com/simplex-chat/simplexmq.git synced 2026-06-07 15:22:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

shadowing

Browse Source
This commit is contained in:
Evgeny Poberezkin
2024-08-26 10:21:22 +01:00
parent 756a1398a6
commit 60783fd9dd
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Simplex/Messaging/Server.hs
+2 -2
View File
@@ -732,9 +732,9 @@ send th c@Client {sndQ, msgQ, sessionId} stats = do
-- with other requests responses.
mapM_ (atomically . writeTBQueue msgQ) $ L.nonEmpty msgs_
splitMessages :: [Transmission BrokerMsg] -> Transmission BrokerMsg -> ([Transmission BrokerMsg], Transmission BrokerMsg)
splitMessages msgs t@(corrId, entId, cmd) = case cmd of
splitMessages msgs t@(corrId, entId, cmd') = case cmd' of
-- replace MSG response with OK, accumulating MSG in a separate list.
MSG {} -> ((CorrId "", entId, cmd) : msgs, (corrId, entId, OK))
MSG {} -> ((CorrId "", entId, cmd') : msgs, (corrId, entId, OK))
_ -> (msgs, t)
sendMsg :: Transport c => MVar (THandleSMP c 'TServer) -> Client -> IO ()