| Safe Haskell | Safe |
|---|---|
| Language | Haskell2010 |
Piped.Resume
Synopsis
- createResumableSource :: Monad m => Pipe () o m a -> ResumableSource o m a b
- createResumableSink :: Monad m => Pipe i Void m b -> ResumableSink i m a b
- runResumableSource :: Monad m => ResumableSource i m a b -> Pipe i Void m b -> m (ResumableResult i m a b)
- runResumableSink :: Monad m => Pipe () o m a -> ResumableSink o m a b -> m (ResumableResult o m a b)
- newtype ResumableSource o m a b = ResumableSource (Await o m (ResumableResult o m a b))
- newtype ResumableSink i m a b = ResumableSink (Yield i m (ResumableResult i m a b))
- data ResumableResult e m a b
- = ResumeSource (ResumableSource e m a b) b
- | ResumeSink (ResumableSink e m a b) a
Documentation
createResumableSource :: Monad m => Pipe () o m a -> ResumableSource o m a b Source #
Create a resumable source from a Pipe
createResumableSink :: Monad m => Pipe i Void m b -> ResumableSink i m a b Source #
Create a resumable sink from a Pipe
runResumableSource :: Monad m => ResumableSource i m a b -> Pipe i Void m b -> m (ResumableResult i m a b) Source #
Run a resumable source
runResumableSink :: Monad m => Pipe () o m a -> ResumableSink o m a b -> m (ResumableResult o m a b) Source #
Run a resumable sink
newtype ResumableSource o m a b Source #
A source that may be resumed
Constructors
| ResumableSource (Await o m (ResumableResult o m a b)) |
newtype ResumableSink i m a b Source #
A sink that may be resumed
Constructors
| ResumableSink (Yield i m (ResumableResult i m a b)) |
data ResumableResult e m a b Source #
Either a resumable source or sink, plus the result of the pipe that finished.
Constructors
| ResumeSource (ResumableSource e m a b) b | |
| ResumeSink (ResumableSink e m a b) a |