hercules-ci-agent-0.9.9: Runs Continuous Integration tasks on your machines
Safe HaskellSafe-Inferred
LanguageHaskell2010

Data.Conduit.Extras

Synopsis

Documentation

sinkChanTerminate :: (MonadUnliftIO m, MonadIO m) => Chan (Maybe a) -> ConduitT a o m () Source #

Write to a channel terminating with Nothing

sinkChan :: (MonadUnliftIO m, MonadIO m) => Chan (Maybe a) -> ConduitT a o m () Source #

Write to a channel terminating with Nothing

sourceChan :: MonadIO m => Chan (Maybe a) -> ConduitT i a m () Source #

Read a channel until Nothing is encountered

conduitToCallbacks :: (MonadUnliftIO m, MonadIO m) => ConduitT () o m a -> (o -> m ()) -> m a Source #