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 StreamConduitM i o m r = Stream m i () -> Stream m o r
• type StreamConduit i m o = StreamConduitM i o m ()
• type StreamSource m o = StreamConduitM () o m ()
• type StreamProducer m o = forall i. StreamConduitM i o m ()
• type StreamSink i m r = StreamConduitM i Void m r
• type StreamConsumer i m r = forall o. StreamConduitM i o m r
• streamConduit :: ConduitM 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 -> ConduitM i o m r

Types

Functions