github/semantic
1
1
Fork 0
mirror of https://github.com/github/semantic.git synced 2024-12-21 05:41:54 +03:00
Code Issues Projects Releases Wiki Activity

Rename writeThread to sink.

Browse Source
This commit is contained in:
Rob Rix 2017-07-21 13:34:01 -04:00
parent e6bb7d6863
commit 3c0ed9029f
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/Semantic/Task.hs
View File

@ -127,7 +127,7 @@ distributeFoldMap toTask inputs = fmap fold (distribute (fmap toTask inputs))
runTask :: Task a -> IO a runTask :: Task a -> IO a
runTask task = do runTask task = do
logQueue <- newTMQueueIO logQueue <- newTMQueueIO
logging <- async (writeThread logQueue) logging <- async (sink logQueue)
result <- runFreerM (\ task -> case task of result <- runFreerM (\ task -> case task of
ReadBlobs source -> pure <$ writeLog (Info "ReadBlobs") <*> either Files.readBlobsFromHandle (traverse (uncurry Files.readFile)) source ReadBlobs source -> pure <$ writeLog (Info "ReadBlobs") <*> either Files.readBlobsFromHandle (traverse (uncurry Files.readFile)) source
@ -144,12 +144,12 @@ runTask task = do
atomically (closeTMQueue logQueue) atomically (closeTMQueue logQueue)
wait logging wait logging
pure result pure result
where writeThread queue = do where sink queue = do
message <- atomically (readTMQueue queue) message <- atomically (readTMQueue queue)
case message of case message of
Just message -> do Just message -> do
B.hPutStr stderr (formatMessage message) B.hPutStr stderr (formatMessage message)
writeThread queue sink queue
_ -> pure () _ -> pure ()