From 9d9bbb6a77e30ef2175eb979aa288eb8e372f20e Mon Sep 17 00:00:00 2001 From: Denis Tereshkin Date: Wed, 5 Jan 2022 09:54:41 +0700 Subject: [PATCH] cleanup --- src/ATrade/MDS/HistoryServer.hs | 3 --- 1 file changed, 3 deletions(-) diff --git a/src/ATrade/MDS/HistoryServer.hs b/src/ATrade/MDS/HistoryServer.hs index c452944..bb5ae5b 100644 --- a/src/ATrade/MDS/HistoryServer.hs +++ b/src/ATrade/MDS/HistoryServer.hs @@ -61,9 +61,6 @@ serveQHP db sock = forever $ do debugM "QHP" $ "Incoming command: " ++ show cmd let dataC = getDataConduit db (replaceWildcards $ rqTicker rq) (TimeInterval (rqStartTime rq) (rqEndTime rq)) (Timeframe (periodSeconds $ rqPeriod rq)) runConduit $ dataC .| (conduitVector chunkSize) .| (sendChunks peerId) - --qdata <- getData db (rqTicker rq) (TimeInterval (rqStartTime rq) (rqEndTime rq)) (Timeframe (periodSeconds $ rqPeriod rq)) - --let bytes = serializeBars $ V.concat $ fmap snd qdata - --sendMulti sock $ peerId :| [B.empty, "OK", BL.toStrict bytes] sendChunks :: (MonadIO m) => B.ByteString -> ConduitT (V.Vector Bar) Void m () sendChunks peerId = do liftIO $ send sock [SendMore] peerId