Data.Conduit.Internal.List.Stream · conduit-1.3.6.1

valueunfoldS :: Monad m => (b -> Maybe (a, b)) -> b -> StreamProducer m a

#

valueunfoldEitherS

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

#

valueunfoldMS :: Monad m => (b -> m (Maybe (a, b))) -> b -> StreamProducer m a

#

valueunfoldEitherMS

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

#

valuesourceListS :: Monad m => [a] -> StreamProducer m a

#

valueenumFromToS :: (Enum a, Ord a, Monad m) => a -> a -> StreamProducer m a

#

valueenumFromToS_int :: (Integral a, Monad m) => a -> a -> StreamProducer m a

#

valueiterateS :: Monad m => (a -> a) -> a -> StreamProducer m a

#

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

#

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

#

valuefoldS :: Monad m => (b -> a -> b) -> b -> StreamConsumer a m b

#

valuefoldMS :: Monad m => (b -> a -> m b) -> b -> StreamConsumer a m b

#

valuemapM_S :: Monad m => (a -> m ()) -> StreamConsumer a m ()

#

valuedropS :: Monad m => Int -> StreamConsumer a m ()

#

valuetakeS :: Monad m => Int -> StreamConsumer a m [a]

#

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

#

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

#

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

#

valueiterMS :: Monad m => (a -> m ()) -> StreamConduit a m a

#

valuemapMaybeS :: Monad m => (a -> Maybe b) -> StreamConduit a m b

#

valuemapMaybeMS :: Monad m => (a -> m (Maybe b)) -> StreamConduit a m b

#

valuecatMaybesS :: Monad m => StreamConduit (Maybe a) m a

#

valueconcatS :: (Monad m, Foldable f) => StreamConduit (f a) m a

#

valueconcatMapS :: Monad m => (a -> [b]) -> StreamConduit a m b

#

valueconcatMapMS :: Monad m => (a -> m [b]) -> StreamConduit a m b

#

valueconcatMapAccumS

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

#

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

#

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

#

valueconcatMapAccumMS

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

#

valuemapFoldableS :: (Monad m, Foldable f) => (a -> f b) -> StreamConduit a m b

#

valuemapFoldableMS

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

#

valueconsumeS :: Monad m => StreamConsumer a m [a]

#

valuegroupByS :: Monad m => (a -> a -> Bool) -> StreamConduit a m [a]

#

valuegroupOn1S :: (Monad m, Eq b) => (a -> b) -> StreamConduit a m (a, [a])

#

datadata GroupByState a b s

#

Constructors

GBStart s
GBLoop ([a] -> [a]) a b s
GBDone

valuegroupBy1S

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

#

valueisolateS :: Monad m => Int -> StreamConduit a m a

#

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

#

valuesinkNullS :: Monad m => StreamConsumer a m ()

#

valuesourceNullS :: Monad m => StreamProducer m a

#