Streamly.Internal.Data.Stream.Common

Low level functions using StreamK as the intermediate stream type. These functions are used in other stream modules to implement their instances.

Conversion operations

fromList :: Monad m => [a] -> StreamK m a

fromList = foldr cons nil

Construct a stream from a list of pure values. This is more efficient than fromFoldable for serial streams.

toList :: Monad m => StreamK m a -> m [a]

Convert a stream into a list in the underlying monad.

Fold operations

foldr :: Monad m => (a -> b -> b) -> b -> StreamK m a -> m b

foldl' :: Monad m => (b -> a -> b) -> b -> StreamK m a -> m b

Strict left associative fold.

fold :: Monad m => Fold m a b -> StreamK m a -> m b

Zip style operations

eqBy :: Monad m => (a -> b -> Bool) -> StreamK m a -> StreamK m b -> m Bool

Compare two streams for equality

cmpBy :: Monad m => (a -> b -> Ordering) -> StreamK m a -> StreamK m b -> m Ordering

Compare two streams