Data.Conduit.Internal.Fusion

Types

data Step s o r

This is the same as stream fusion's Step. Constructors are renamed to avoid confusion with conduit names.

Constructors

Emit s o

Skip s

Stop r

Instances

Functor (Step s o)

Methods

fmap :: (a -> b) -> Step s o a -> Step s o b

(<$) :: a -> Step s o b -> Step s o a

data Stream m o r

Constructors

Stream (s -> m (Step s o r)) (m s)

data ConduitWithStream i o m r

type StreamConduitT i o m r = Stream m i () -> Stream m o r

type StreamConduit i m o = StreamConduitT i o m ()

type StreamSource m o = StreamConduitT () o m ()

type StreamProducer m o = forall i. StreamConduitT i o m ()

type StreamSink i m r = StreamConduitT i Void m r

type StreamConsumer i m r = forall o. StreamConduitT i o m r

Functions

streamConduit :: ConduitT i o m r -> (Stream m i () -> Stream m o r) -> ConduitWithStream i o m r

streamSource :: Monad m => Stream m o () -> ConduitWithStream i o m ()

streamSourcePure :: Monad m => Stream Identity o () -> ConduitWithStream i o m ()

unstream :: ConduitWithStream i o m r -> ConduitT i o m r