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

Functions