From 035aa0da365cf22c56f703965c6de56e54a51429 Mon Sep 17 00:00:00 2001 From: Denis Tereshkin Date: Tue, 4 Jan 2022 23:00:46 +0700 Subject: [PATCH] junction: format RobotDriverThread --- .../Driver/Junction/RobotDriverThread.hs | 18 +++++++++++------- 1 file changed, 11 insertions(+), 7 deletions(-) diff --git a/src/ATrade/Driver/Junction/RobotDriverThread.hs b/src/ATrade/Driver/Junction/RobotDriverThread.hs index 551a0cc..2f18599 100644 --- a/src/ATrade/Driver/Junction/RobotDriverThread.hs +++ b/src/ATrade/Driver/Junction/RobotDriverThread.hs @@ -20,7 +20,8 @@ module ATrade.Driver.Junction.RobotDriverThread import ATrade.Broker.Protocol (Notification (OrderNotification, TradeNotification)) import qualified ATrade.Driver.Junction.BrokerService as Bro import ATrade.Driver.Junction.QuoteStream (QuoteStream (addSubscription, removeSubscription), - QuoteSubscription (QuoteSubscription), SubscriptionId) + QuoteSubscription (QuoteSubscription), + SubscriptionId) import ATrade.Driver.Junction.Types (BigConfig, StrategyDescriptor, StrategyInstance (StrategyInstance, strategyEventCallback), @@ -34,25 +35,28 @@ import ATrade.Logging (Message, log) import ATrade.QuoteSource.Client (QuoteData (..)) import ATrade.RoboCom.ConfigStorage (ConfigStorage) import ATrade.RoboCom.Monad (Event (NewBar, NewTick, NewTrade, OrderUpdate), - MonadRobot (..), StrategyEnvironment (..)) + MonadRobot (..), + StrategyEnvironment (..)) import ATrade.RoboCom.Persistence (MonadPersistence) import ATrade.RoboCom.Types (BarSeriesId (BarSeriesId), Bars, TickerInfoMap) -import ATrade.Types (OrderId, - OrderState, Trade, Tick (value)) +import ATrade.Types (OrderId, OrderState, + Tick (value), Trade) import Colog (HasLog (getLogAction, setLogAction), LogAction) -import Control.Concurrent (ThreadId, forkIO, killThread) +import Control.Concurrent (ThreadId, forkIO, + killThread) import Control.Concurrent.BoundedChan (BoundedChan, newBoundedChan, readChan, writeChan) import Control.Exception.Safe (MonadThrow) -import Control.Monad (forM_, forever, void, when, forM) +import Control.Monad (forM, forM_, forever, + void, when) import Control.Monad.IO.Class (MonadIO, liftIO) import Control.Monad.Reader (MonadReader (local), ReaderT, asks) import Data.Aeson (FromJSON, ToJSON) -import Data.Default ( Default ) +import Data.Default (Default) import Data.IORef (IORef, atomicModifyIORef', readIORef, writeIORef)