Documentation

unfoldS :: Monad m => (b -> Maybe (a, b)) -> b -> StreamProducer m a Source #

unfoldEitherS :: Monad m => (b -> Either r (a, b)) -> b -> StreamConduitT i a m r Source #

unfoldMS :: Monad m => (b -> m ( Maybe (a, b))) -> b -> StreamProducer m a Source #

unfoldEitherMS :: Monad m => (b -> m ( Either r (a, b))) -> b -> StreamConduitT i a m r Source #

sourceListS :: Monad m => [a] -> StreamProducer m a Source #

enumFromToS :: ( Enum a, Ord a, Monad m) => a -> a -> StreamProducer m a Source #

enumFromToS_int :: ( Integral a, Monad m) => a -> a -> StreamProducer m a Source #

iterateS :: Monad m => (a -> a) -> a -> StreamProducer m a Source #

replicateS :: Monad m => Int -> a -> StreamProducer m a Source #

replicateMS :: Monad m => Int -> m a -> StreamProducer m a Source #

foldS :: Monad m => (b -> a -> b) -> b -> StreamConsumer a m b Source #

foldMS :: Monad m => (b -> a -> m b) -> b -> StreamConsumer a m b Source #

mapM_S :: Monad m => (a -> m ()) -> StreamConsumer a m () Source #

dropS :: Monad m => Int -> StreamConsumer a m () Source #

takeS :: Monad m => Int -> StreamConsumer a m [a] Source #

headS :: Monad m => StreamConsumer a m ( Maybe a) Source #

mapS :: Monad m => (a -> b) -> StreamConduit a m b Source #

mapMS :: Monad m => (a -> m b) -> StreamConduit a m b Source #

iterMS :: Monad m => (a -> m ()) -> StreamConduit a m a Source #

mapMaybeS :: Monad m => (a -> Maybe b) -> StreamConduit a m b Source #

mapMaybeMS :: Monad m => (a -> m ( Maybe b)) -> StreamConduit a m b Source #

catMaybesS :: Monad m => StreamConduit ( Maybe a) m a Source #

concatS :: ( Monad m, Foldable f) => StreamConduit (f a) m a Source #

concatMapS :: Monad m => (a -> [b]) -> StreamConduit a m b Source #

concatMapMS :: Monad m => (a -> m [b]) -> StreamConduit a m b Source #

concatMapAccumS :: Monad m => (a -> accum -> (accum, [b])) -> accum -> StreamConduit a m b Source #

mapAccumS :: Monad m => (a -> s -> (s, b)) -> s -> StreamConduitT a b m s Source #

mapAccumMS :: Monad m => (a -> s -> m (s, b)) -> s -> StreamConduitT a b m s Source #

concatMapAccumMS :: Monad m => (a -> accum -> m (accum, [b])) -> accum -> StreamConduit a m b Source #

mapFoldableS :: ( Monad m, Foldable f) => (a -> f b) -> StreamConduit a m b Source #

mapFoldableMS :: ( Monad m, Foldable f) => (a -> m (f b)) -> StreamConduit a m b Source #

consumeS :: Monad m => StreamConsumer a m [a] Source #

groupByS :: Monad m => (a -> a -> Bool ) -> StreamConduit a m [a] Source #

groupOn1S :: ( Monad m, Eq b) => (a -> b) -> StreamConduit a m (a, [a]) Source #

data GroupByState a b s Source #

groupBy1S :: Monad m => (a -> b) -> (b -> b -> Bool ) -> StreamConduit a m (a, [a]) Source #

isolateS :: Monad m => Int -> StreamConduit a m a Source #

filterS :: Monad m => (a -> Bool ) -> StreamConduit a m a Source #

sinkNullS :: Monad m => StreamConsumer a m () Source #

sourceNullS :: Monad m => StreamProducer m a Source #