aboutsummaryrefslogtreecommitdiff
path: root/server/src/Thermoprint/Server/Printer.hs
diff options
context:
space:
mode:
Diffstat (limited to 'server/src/Thermoprint/Server/Printer.hs')
-rw-r--r--server/src/Thermoprint/Server/Printer.hs8
1 files changed, 4 insertions, 4 deletions
diff --git a/server/src/Thermoprint/Server/Printer.hs b/server/src/Thermoprint/Server/Printer.hs
index 7f41430..5dc593e 100644
--- a/server/src/Thermoprint/Server/Printer.hs
+++ b/server/src/Thermoprint/Server/Printer.hs
@@ -25,7 +25,7 @@ import Thermoprint.Server.Database
25import Database.Persist 25import Database.Persist
26import Database.Persist.Sql 26import Database.Persist.Sql
27 27
28import Data.Sequence (Seq, ViewL(..), viewl, (<|), (|>)) 28import Data.Sequence (Seq, ViewR(..), viewr, (<|), (|>))
29import qualified Data.Sequence as Seq 29import qualified Data.Sequence as Seq
30import Data.Map (Map) 30import Data.Map (Map)
31import qualified Data.Map as Map 31import qualified Data.Map as Map
@@ -91,9 +91,9 @@ runPrinter :: ( MonadReader ConnectionPool m
91runPrinter Printer{..} = forever $ do 91runPrinter Printer{..} = forever $ do
92 entry@(QueueEntry{..}) <- atomically' $ do 92 entry@(QueueEntry{..}) <- atomically' $ do
93 (Queue queuePending Nothing history) <- readTVar queue 93 (Queue queuePending Nothing history) <- readTVar queue
94 case viewl queuePending of 94 case viewr queuePending of
95 EmptyL -> retry 95 EmptyR -> retry
96 (current :< remaining) -> do 96 (remaining :> current) -> do
97 writeTVar queue $!! Queue remaining (Just current) history 97 writeTVar queue $!! Queue remaining (Just current) history
98 return current 98 return current
99 job <- runSqlPool (get jobId) =<< ask 99 job <- runSqlPool (get jobId) =<< ask