Data.Conduit.Extras
sourceChan :: MonadIO m => Chan (Maybe a) -> ConduitT i a m () Source #
Read a channel until Nothing is encountered
Nothing
conduitToCallbacks :: MonadIO m => ConduitT () o m a -> (o -> m ()) -> m a Source #