From 4c88aba7c62a5c05f6f66d93dbbc50b795b67ad2 Mon Sep 17 00:00:00 2001 From: Denis Tereshkin Date: Thu, 1 Dec 2016 18:49:12 +0700 Subject: [PATCH] Bugfix: added delay when sending heartbeat --- src/ATrade/Broker/Server.hs | 1 + 1 file changed, 1 insertion(+) diff --git a/src/ATrade/Broker/Server.hs b/src/ATrade/Broker/Server.hs index 847c760..6bfbee3 100644 --- a/src/ATrade/Broker/Server.hs +++ b/src/ATrade/Broker/Server.hs @@ -109,6 +109,7 @@ tradeSinkHandler c state tradeSinkEp = when (tradeSinkEp /= "") $ case maybeTrade of Just trade -> sendMulti sock $ B.empty :| [encodeTrade trade] Nothing -> do + threadDelay 1000000 sendMulti sock $ B.empty :| [BL.toStrict $ encode TradeSinkHeartBeat] events <- poll 5000 [Sock sock [In] Nothing] if not . L.null . L.head $ events