Streamly.Internal.Data.Producer.Type

Contents

Description

Synopsis

data Producer m a b = forall s. Producer (s -> m (Step s b)) (a -> m s) (s -> m a)
nil :: Monad m => Producer m a b
nilM :: Monad m => (a -> m c) -> Producer m a b
unfoldrM :: Monad m => (a -> m (Maybe (b, a))) -> Producer m a b
fromList :: Monad m => Producer m [a] a
translate :: Functor m => (a -> c) -> (c -> a) -> Producer m c b -> Producer m a b
lmap :: (a -> a) -> Producer m a b -> Producer m a b
data NestedLoop s1 s2
- = OuterLoop s1
- | InnerLoop s1 s2
concat :: Monad m => Producer m a b -> Producer m b c -> Producer m (NestedLoop a b) c

Type

A Producer m a b is a generator of a stream of values of type b from a seed of type a in Monad m.

Pre-release

Constructors

forall s. Producer (s -> m (Step s b)) (a -> m s) (s -> m a)

Producer step inject extract

Instances details

Functor m => Functor (Producer m a) Source #	Maps a function on the output of the producer (the type `b`).
Instance details Defined in Streamly.Internal.Data.Producer.Type Methods fmap :: (a0 -> b) -> Producer m a a0 -> Producer m a b # (<$) :: a0 -> Producer m a b -> Producer m a a0 #

Producers

nilM :: Monad m => (a -> m c) -> Producer m a b Source #

unfoldrM :: Monad m => (a -> m (Maybe (b, a))) -> Producer m a b Source #

Convert a list of pure values to a Stream

Pre-release

translate :: Functor m => (a -> c) -> (c -> a) -> Producer m c b -> Producer m a b Source #

Interconvert the producer between two interconvertible input types.

Pre-release

lmap :: (a -> a) -> Producer m a b -> Producer m a b Source #

Map the producer input to another value of the same type.

Pre-release

State representing a nested loop.

Constructors

OuterLoop s1
InnerLoop s1 s2

Apply the second unfold to each output element of the first unfold and flatten the output in a single stream.

Pre-release