Data.Conduit

Core interface

Types

type Source m o

type Conduit i m o

type Sink i

data ConduitM i o m r

Connect/fuse operators

(.|)

($$)

($=)

(=$)

(=$=)

connect

fuse

Fuse with upstream results

fuseBoth

fuseBothMaybe

fuseUpstream

Primitives

await

yield

yieldM

leftover

runConduit

runConduitPure

runConduitRes

Finalization

bracketP

addCleanup

yieldOr

Exception handling

catchC

handleC

tryC

Generalized conduit types

type Producer m o

type Consumer i m r

toProducer

toConsumer

Utility functions

awaitForever

transPipe

mapOutput

mapOutputMaybe

mapInput

mergeSource

passthroughSink

sourceToList

Connect-and-resume

data ResumableSource m o

newResumableSource

($$+)

($$++)

($$+-)

($=+)

unwrapResumable

closeResumableSource

For Conduits

data ResumableConduit i m o

newResumableConduit

(=$$+)

(=$$++)

(=$$+-)

unwrapResumableConduit

Fusion with leftovers

fuseLeftovers

fuseReturnLeftovers

Flushing

data Flush a

Newtype wrappers

ZipSource

data ZipSource m o

sequenceSources

ZipSink

data ZipSink i m r

sequenceSinks

ZipConduit

data ZipConduit i o m r

sequenceConduits