module Data.Conduit
(
Source
, Conduit
, Sink
, ConduitM
, ($$)
, ($=)
, (=$)
, (=$=)
, connect
, fuse
, fuseBoth
, fuseUpstream
, await
, yield
, leftover
, runConduit
, bracketP
, addCleanup
, yieldOr
, catchC
, handleC
, tryC
, Producer
, Consumer
, toProducer
, toConsumer
, awaitForever
, transPipe
, mapOutput
, mapOutputMaybe
, mapInput
, passthroughSink
, ResumableSource
, newResumableSource
, ($$+)
, ($$++)
, ($$+-)
, ($=+)
, unwrapResumable
, closeResumableSource
, ResumableConduit
, newResumableConduit
, (=$$+)
, (=$$++)
, (=$$+-)
, unwrapResumableConduit
, fuseLeftovers
, fuseReturnLeftovers
, Flush (..)
, ZipSource (..)
, sequenceSources
, ZipSink (..)
, sequenceSinks
, ZipConduit (..)
, sequenceConduits
) where
import Data.Conduit.Internal.Conduit
connect :: Monad m => Source m a -> Sink a m b -> m b
connect = ($$)
fuse :: Monad m => Conduit a m b -> ConduitM b c m r -> ConduitM a c m r
fuse = (=$=)