From e4aaa9ce7251aa2ea50844c6ff089eddfb3a20b7 Mon Sep 17 00:00:00 2001 From: Evgeny Poberezkin Date: Sun, 7 Sep 2025 12:36:37 +0100 Subject: [PATCH] flush --- src/Simplex/Messaging/Server.hs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/Simplex/Messaging/Server.hs b/src/Simplex/Messaging/Server.hs index fa6d17eee..bc88d6cc9 100644 --- a/src/Simplex/Messaging/Server.hs +++ b/src/Simplex/Messaging/Server.hs @@ -2124,7 +2124,9 @@ exportMessages tty ms f drainMsgs = do msgs <- unsafeRunStore q "saveQueueMsgs" $ getQueueMessages_ drainMsgs q =<< getMsgQueue ms q False - unless (null msgs) $ BLD.hPutBuilder h $ encodeMessages (recipientId q) msgs + unless (null msgs) $ do + BLD.hPutBuilder h $! encodeMessages (recipientId q) msgs + hFlush h pure $ Sum $ length msgs encodeMessages rId = mconcat . map (\msg -> BLD.byteString (strEncode $ MLRv3 rId msg) <> BLD.char8 '\n')