From 21f9a01b264223a1a525a429affc62368be42fd7 Mon Sep 17 00:00:00 2001 From: Denis Tereshkin Date: Wed, 5 Oct 2016 15:55:56 +0700 Subject: [PATCH] QuoteSource client: bugfix --- src/ATrade/QuoteSource/Client.hs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/ATrade/QuoteSource/Client.hs b/src/ATrade/QuoteSource/Client.hs index 289ad8d..e15c2cc 100644 --- a/src/ATrade/QuoteSource/Client.hs +++ b/src/ATrade/QuoteSource/Client.hs @@ -34,7 +34,7 @@ startQuoteSourceClient chan tickers ctx endpoint = do finally (clientThread sock) (cleanup compMv sock) return QuoteSourceClientHandle { tid = tid, completionMvar = compMv } where - clientThread sock = do + clientThread sock = forever $ do evs <- poll 200 [Sock sock [In] Nothing] when ((L.length . L.head) evs > 0) $ do rawTick <- fmap BL.fromStrict <$> receiveMulti sock