| Copyright | (c) 2017 Composewell Technologies |
|---|---|
| License | BSD-3-Clause |
| Maintainer | streamly@composewell.com |
| Stability | experimental |
| Portability | GHC |
| Safe Haskell | Safe-Inferred |
| Language | Haskell2010 |
Streamly.Internal.Data.Stream.Concurrent.Channel.Consumer
Description
Synopsis
- readOutputQPaced :: MonadRunInIO m => Channel m a -> m [ChildEvent a]
- readOutputQBounded :: MonadRunInIO m => Bool -> Channel m a -> m [ChildEvent a]
- postProcessPaced :: MonadRunInIO m => Channel m a -> m Bool
- postProcessBounded :: MonadRunInIO m => Channel m a -> m Bool
Read Output
readOutputQPaced :: MonadRunInIO m => Channel m a -> m [ChildEvent a] Source #
readOutputQBounded :: MonadRunInIO m => Bool -> Channel m a -> m [ChildEvent a] Source #
Postprocess Hook After Reading
postProcessPaced :: MonadRunInIO m => Channel m a -> m Bool Source #
postProcessBounded :: MonadRunInIO m => Channel m a -> m Bool Source #