Data.Conduit.ResumableSink

Documentation

data ResumableSink i m r

Constructors

ResumableSink (Sink i m r)

connectResumeSink :: Monad m => Source m i -> ResumableSink i m r -> m (Either r (ResumableSink i m r))

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 i m r

Converts a sink into a ResumableSink that can be used with ++$$

closeResumableSink :: Monad m => ResumableSink i m r -> m r

Closes a ResumableSink and gets the final result.

(+$$) :: Monad m => Source m i -> Sink i m r -> m (Either r (ResumableSink i m r))

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 i m r -> m (Either r (ResumableSink i m r))

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 i m r -> m r

Attaches a source to a resumable sink, finishing the sink and returning a result.