Run.Streaming.Pull

identity :: forall a o i r. i -> Run (Pipe i o i o r) a

chain :: forall a o i r. (i -> Run (Server i o r) a) -> Run (Client i o r) a -> Run r a

Connects a Server to a Client which can fulfill requests from the Client.

traverse :: forall a o i r. (i -> Run r o) -> Run (Client i o r) a -> Run r a

Fulfills a Client with effects.

for :: forall a o i r. Run (Client i o r) a -> (i -> Run r o) -> Run r a

traverse with the arguments flipped.

compose :: forall a x o i r. (i -> Run (Server i o r) a) -> (x -> Run (Client i o r) a) -> (x -> Run r a)

Point-free pull composition.

composeFlipped :: forall a x o i r. (x -> Run (Client i o r) a) -> (i -> Run (Server i o r) a) -> (x -> Run r a)

compose with the arguments flipped.

feed :: forall a x r. Run (Consumer x r) a -> Run (Producer x r) a -> Run r a

Connects a Consumer to a Producer.

draw :: forall a x r. Run (Producer x r) a -> Run (Consumer x r) a -> Run r a

Connects a Producer to a Consumer.

into :: forall a x r. Run (Consumer x r) a -> Run r x -> Run r a

Connects a Consumer to an effect which fulfills the request.

from :: forall a x r. Run r x -> Run (Consumer x r) a -> Run r a

Connect an effect to a Consumer, fulfilling the request.

consume :: forall b a x r. (x -> Run (Consumer x r) a) -> Run (Consumer x r) b

Consumes all values with effects.