| Safe Haskell | None |
|---|---|
| Language | Haskell98 |
Data.Conduit.Combinators.Stream
Description
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.
- yieldManyS :: (Monad m, MonoFoldable mono) => mono -> StreamProducer m (Element mono)
- repeatMS :: Monad m => m a -> StreamProducer m a
- repeatWhileMS :: Monad m => m a -> (a -> Bool) -> StreamProducer m a
- sourceHandleS :: (MonadIO m, IOData a) => Handle -> StreamProducer m a
- foldl1S :: Monad m => (a -> a -> a) -> StreamConsumer a m (Maybe a)
- allS :: Monad m => (a -> Bool) -> StreamConsumer a m Bool
- anyS :: Monad m => (a -> Bool) -> StreamConsumer a m Bool
- sinkLazyS :: (Monad m, LazySequence lazy strict) => StreamConsumer strict m lazy
- sinkVectorS :: (MonadBase base m, Vector v a, PrimMonad base) => StreamConsumer a m (v a)
- sinkVectorNS :: (MonadBase base m, Vector v a, PrimMonad base) => Int -> StreamConsumer a m (v a)
- sinkLazyBuilderS :: (Monad m, Monoid builder, ToBuilder a builder, Builder builder lazy) => StreamConsumer a m lazy
- lastS :: Monad m => StreamConsumer a m (Maybe a)
- lastES :: (Monad m, IsSequence seq) => StreamConsumer seq m (Maybe (Element seq))
- findS :: Monad m => (a -> Bool) -> StreamConsumer a m (Maybe a)
- concatMapS :: (Monad m, MonoFoldable mono) => (a -> mono) -> StreamConduit a m (Element mono)
- concatMapMS :: (Monad m, MonoFoldable mono) => (a -> m mono) -> StreamConduit a m (Element mono)
- concatS :: (Monad m, MonoFoldable mono) => StreamConduit mono m (Element mono)
- scanlS :: Monad m => (a -> b -> a) -> a -> StreamConduit b m a
- scanlMS :: Monad m => (a -> b -> m a) -> a -> StreamConduit b m a
- intersperseS :: Monad m => a -> StreamConduit a m a
- slidingWindowS :: (Monad m, IsSequence seq, Element seq ~ a) => Int -> StreamConduit a m seq
- filterMS :: Monad m => (a -> m Bool) -> StreamConduit a m a
- splitOnUnboundedES :: (Monad m, IsSequence seq) => (Element seq -> Bool) -> StreamConduit seq m seq
- initReplicateS :: Monad m => m seed -> (seed -> m a) -> Int -> StreamProducer m a
- initRepeatS :: Monad m => m seed -> (seed -> m a) -> StreamProducer m a
Documentation
yieldManyS :: (Monad m, MonoFoldable mono) => mono -> StreamProducer m (Element mono) Source
repeatMS :: Monad m => m a -> StreamProducer m a Source
repeatWhileMS :: Monad m => m a -> (a -> Bool) -> StreamProducer m a Source
sourceHandleS :: (MonadIO m, IOData a) => Handle -> StreamProducer m a Source
foldl1S :: Monad m => (a -> a -> a) -> StreamConsumer a m (Maybe a) Source
sinkLazyS :: (Monad m, LazySequence lazy strict) => StreamConsumer strict m lazy Source
sinkVectorS :: (MonadBase base m, Vector v a, PrimMonad base) => StreamConsumer a m (v a) Source
Arguments
| :: (MonadBase base m, Vector v a, PrimMonad base) | |
| => Int | maximum allowed size |
| -> StreamConsumer a m (v a) |
sinkLazyBuilderS :: (Monad m, Monoid builder, ToBuilder a builder, Builder builder lazy) => StreamConsumer a m lazy Source
lastS :: Monad m => StreamConsumer a m (Maybe a) Source
lastES :: (Monad m, IsSequence seq) => StreamConsumer seq m (Maybe (Element seq)) Source
concatMapS :: (Monad m, MonoFoldable mono) => (a -> mono) -> StreamConduit a m (Element mono) Source
concatMapMS :: (Monad m, MonoFoldable mono) => (a -> m mono) -> StreamConduit a m (Element mono) Source
concatS :: (Monad m, MonoFoldable mono) => StreamConduit mono m (Element mono) Source
scanlS :: Monad m => (a -> b -> a) -> a -> StreamConduit b m a Source
scanlMS :: Monad m => (a -> b -> m a) -> a -> StreamConduit b m a Source
intersperseS :: Monad m => a -> StreamConduit a m a Source
slidingWindowS :: (Monad m, IsSequence seq, Element seq ~ a) => Int -> StreamConduit a m seq Source
filterMS :: Monad m => (a -> m Bool) -> StreamConduit a m a Source
splitOnUnboundedES :: (Monad m, IsSequence seq) => (Element seq -> Bool) -> StreamConduit seq m seq Source
initReplicateS :: Monad m => m seed -> (seed -> m a) -> Int -> StreamProducer m a Source
Streaming versions of Data.Conduit.Combinators.Internal.initReplicate
initRepeatS :: Monad m => m seed -> (seed -> m a) -> StreamProducer m a Source
Streaming versions of Data.Conduit.Combinators.Internal.initRepeat