Streamly.Internal.Data.Fold.SVar

Documentation

write :: MonadIO m => SVar t m a -> Maybe WorkerInfo -> Fold m a ()

A fold to write a stream to an SVar. Unlike toSVar this does not allow for concurrent evaluation of the stream, as the fold receives the input one element at a time, it just forwards the elements to the SVar. However, we can safely execute the fold in an independent thread, the SVar can act as a buffer decoupling the sender from the receiver. Also, we can have multiple folds running concurrently pusing the streams to the SVar.

writeLimited :: MonadIO m => SVar t m a -> Maybe WorkerInfo -> Fold m a ()

Like write, but applies a yield limit.