| 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.SVar.Pull
Description
Synopsis
- readOutputQBasic :: IORef ([ChildEvent a], Int) -> IO ([ChildEvent a], Int)
- readOutputQRaw :: SVar t m a -> IO ([ChildEvent a], Int)
- readOutputQPaced :: MonadAsync m => SVar t m a -> m [ChildEvent a]
- readOutputQBounded :: MonadAsync m => SVar t m a -> m [ChildEvent a]
- postProcessPaced :: MonadAsync m => SVar t m a -> m Bool
- postProcessBounded :: MonadAsync m => SVar t m a -> m Bool
- cleanupSVar :: SVar t m a -> IO ()
- cleanupSVarFromWorker :: SVar t m a -> IO ()
Read Output
readOutputQBasic :: IORef ([ChildEvent a], Int) -> IO ([ChildEvent a], Int) Source #
readOutputQRaw :: SVar t m a -> IO ([ChildEvent a], Int) Source #
readOutputQPaced :: MonadAsync m => SVar t m a -> m [ChildEvent a] Source #
readOutputQBounded :: MonadAsync m => SVar t m a -> m [ChildEvent a] Source #
Postprocess Hook After Reading
postProcessPaced :: MonadAsync m => SVar t m a -> m Bool Source #
postProcessBounded :: MonadAsync m => SVar t m a -> m Bool Source #
Release Resources
cleanupSVar :: SVar t m a -> IO () Source #
cleanupSVarFromWorker :: SVar t m a -> IO () Source #