Stream.Core

Types

data StreamT o m r

data Step s o r

Constructors

Done r

Yield s o

Skip s

Helpers

mapStep :: (i -> o) -> Step s i r -> Step s o r

runStreamT :: Monad m => StreamT o m r -> m r

Smart constructros

Source

makeSource :: state -> (state -> m (Step state o r)) -> StreamT o m r

makeSourceWith :: (forall b. (state -> m b) -> m b) -> (state -> m (Step state o r)) -> StreamT o m r

Transformer

makeTransformer :: myState -> (forall upState. myState -> upState -> (upState -> m (Step upState i upR)) -> m (Step (myState, upState) o myR)) -> StreamT i m upR -> StreamT o m myR

makeTransformer' :: (forall upState. upState -> (upState -> m (Step upState i upR)) -> m (Step upState o myR)) -> StreamT i m upR -> StreamT o m myR

Sink

makeSink :: (forall state. state -> (state -> m (Step state i upR)) -> m myR) -> StreamT i m upR -> m myR