Data.Conduit.Internal.Fusion

conduit-1.3.2.1: Streaming data processing library.

Safe Haskell	Trustworthy
Language	Haskell2010

Data.Conduit.Internal.Fusion

Contents

Types
Functions

Synopsis

data Step s o r
- = Emit s o
- | Skip s
- | Stop r
data Stream m o r = 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
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

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 #
Instance details Defined in Data.Conduit.Internal.Fusion 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)

data ConduitWithStream i o m r Source #

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

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

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

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

type StreamSink i m r = StreamConduitT i Void m r Source #

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

Functions

streamConduit :: ConduitT 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 #

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

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