| Safe Haskell | None |
|---|
Data.Conduit.ResumableSink
- data ResumableSink m i r = ResumableSink (Sink i m r)
- connectResumeSink :: Monad m => Source m i -> ResumableSink m i r -> m (Either r (ResumableSink m i r))
- newResumableSink :: Monad m => Sink i m r -> ResumableSink m i r
- closeResumableSink :: Monad m => ResumableSink m i r -> m r
- (+$$) :: Monad m => Source m i -> Sink i m r -> m (Either r (ResumableSink m i r))
- (++$$) :: Monad m => Source m i -> ResumableSink m i r -> m (Either r (ResumableSink m i r))
- (-++$$) :: Monad m => Source m i -> ResumableSink m i r -> m r
Documentation
data ResumableSink m i r Source
Constructors
| ResumableSink (Sink i m r) |
connectResumeSink :: Monad m => Source m i -> ResumableSink m i r -> m (Either r (ResumableSink m i r))Source
Connects a new source to a resumable sink. The result will be Right an updated ResumableSink or Left result if the Sink completes.
newResumableSink :: Monad m => Sink i m r -> ResumableSink m i rSource
Converts a sink into a ResumableSink that can be used with ++$$
closeResumableSink :: Monad m => ResumableSink m i r -> m rSource
Closes a ResumableSink and gets the final result.
(+$$) :: Monad m => Source m i -> Sink i m r -> m (Either r (ResumableSink m i r))Source
Connects a source and a sink. The result will be Right a ResumableSink or Left result if the Sink completes.
(++$$) :: Monad m => Source m i -> ResumableSink m i r -> m (Either r (ResumableSink m i r))Source
Connects a new source to a resumable sink. The result will be Right an updated ResumableSink or Left result if the Sink completes.
(-++$$) :: Monad m => Source m i -> ResumableSink m i r -> m rSource
Attaches a source to a resumable sink, finishing the sink and returning a result.