Skip to content

Commit

Permalink
Correct documentation of sinkTBQueue
Browse files Browse the repository at this point in the history
  • Loading branch information
eriknstevenson authored and qnikst committed Dec 6, 2016
1 parent b3b82b7 commit 8f96012
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions Data/Conduit/TQueue.hs
Original file line number Diff line number Diff line change
Expand Up @@ -76,8 +76,7 @@ sourceTBQueue :: MonadIO m => TBQueue a -> Source m a
sourceTBQueue q = forever $ liftSTM (readTBQueue q) >>= yield

-- | A simple wrapper around a "TBQueue". As data is pushed into this sink, it
-- will magically begin to appear in the queue. Boolean argument is used
-- to specify if queue should be closed when the sink is closed.
-- will magically begin to appear in the queue.
sinkTBQueue :: MonadIO m => TBQueue a -> Sink a m ()
sinkTBQueue q = CL.mapM_ (liftSTM . writeTBQueue q)

Expand Down

0 comments on commit 8f96012

Please sign in to comment.