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.

26 values

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

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

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

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