Moduleconduit-1.3.6.1Haskell2010

Data.Conduit.Combinators.Stream

These are stream fusion versions of some of the functions in Data.Conduit.Combinators. Many functions don't have stream versions here because instead they have RULES which inline a definition that fuses.

Synopsis

value yieldManyS
value repeatMS
value repeatWhileMS
value foldl1S
value allS
value anyS
value sinkLazyS
value sinkVectorS
value sinkVectorNS
value sinkLazyBuilderS
value lastS
value lastES
value findS
value concatMapS
value concatMapMS
value concatS
value scanlS
value scanlMS
value mapAccumWhileS
value mapAccumWhileMS
value intersperseS
value slidingWindowS
value filterMS
value splitOnUnboundedES
value initReplicateS
value initRepeatS

Packageconduit-1.3.6.1
Exports26
LanguageHaskell2010
LicenceMIT
SourceStream.hs

valueyieldManyS

:: (Monad m, MonoFoldable mono)
=> mono
-> StreamProducer m (Element mono)

valuerepeatMS :: Monad m => m a -> StreamProducer m a

valuerepeatWhileMS :: Monad m => m a -> (a -> Bool) -> StreamProducer m a

valuefoldl1S :: Monad m => (a -> a -> a) -> StreamConsumer a m (Maybe a)

valueallS :: Monad m => (a -> Bool) -> StreamConsumer a m Bool

valueanyS :: Monad m => (a -> Bool) -> StreamConsumer a m Bool

valuesinkLazyS :: (Monad m, LazySequence lazy strict) => StreamConsumer strict m lazy

valuesinkVectorS :: (Vector v a, PrimMonad m) => StreamConsumer a m (v a)

valuesinkVectorNS

:: (Vector v a, PrimMonad m)
=> Int
maximum allowed size
-> StreamConsumer a m (v a)

valuesinkLazyBuilderS :: Monad m => StreamConsumer Builder m ByteString

valuelastS :: Monad m => StreamConsumer a m (Maybe a)

valuelastES :: (Monad m, IsSequence seq) => StreamConsumer seq m (Maybe (Element seq))

valuefindS :: Monad m => (a -> Bool) -> StreamConsumer a m (Maybe a)

valueconcatMapS

:: (Monad m, MonoFoldable mono)
=> a -> mono
-> StreamConduit a m (Element mono)

valueconcatMapMS

:: (Monad m, MonoFoldable mono)
=> a -> m mono
-> StreamConduit a m (Element mono)

valueconcatS :: (Monad m, MonoFoldable mono) => StreamConduit mono m (Element mono)

valuescanlS :: Monad m => (a -> b -> a) -> a -> StreamConduit b m a

valuescanlMS :: Monad m => (a -> b -> m a) -> a -> StreamConduit b m a

valuemapAccumWhileS

:: Monad m
=> a -> s -> Either s (s, b)
-> s
-> StreamConduitT a b m s

valuemapAccumWhileMS

:: Monad m
=> a -> s -> m (Either s (s, b))
-> s
-> StreamConduitT a b m s

valueintersperseS :: Monad m => a -> StreamConduit a m a

valueslidingWindowS

:: (Monad m, IsSequence seq, Element seq ~ a)
=> Int
-> StreamConduit a m seq

valuefilterMS :: Monad m => (a -> m Bool) -> StreamConduit a m a

valuesplitOnUnboundedES

:: (Monad m, IsSequence seq)
=> Element seq -> Bool
-> StreamConduit seq m seq

valueinitReplicateS

:: Monad m
=> m seed
-> seed -> m a
-> Int
-> StreamProducer m a

Source#

Streaming versions of Data.Conduit.Combinators.Internal.initReplicate

valueinitRepeatS :: Monad m => m seed -> (seed -> m a) -> StreamProducer m a

Source#

Streaming versions of Data.Conduit.Combinators.Internal.initRepeat