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