conduit-1.2.3.1: Streaming data processing library.

Safe HaskellNone
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) 

data Stream m o r Source

Constructors

forall s . 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