conduit-1.2.9: Streaming data processing library.

Safe HaskellTrustworthy
LanguageHaskell98

Data.Conduit.Internal.Fusion

Contents

Synopsis

Types

data Step s o r Source #

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) Source # 

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 Source #

Constructors

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

type StreamConduitM i o m r = Stream m i () -> Stream m o r Source #

type StreamConduit i m o = StreamConduitM i o m () Source #

type StreamSource m o = StreamConduitM () o m () Source #

type StreamProducer m o = forall i. StreamConduitM i o m () Source #

type StreamConsumer i m r = forall o. StreamConduitM i o m r Source #

Functions

streamConduit :: ConduitM i o m r -> (Stream m i () -> Stream m o r) -> ConduitWithStream i o m r Source #

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