sum package:streamly

sum :: (Monad m, Num a) => SerialT m a -> m a

streamly Streamly.Internal.Data.Stream.IsStream Streamly.Prelude

Determine the sum of all elements of a stream of numbers. Returns 0 when the stream is empty. Note that this is not numerically stable for floating point numbers.

sum = Stream.fold Fold.sum

outputDoorBellFromConsumer :: Channel m a b -> MVar ()

streamly Streamly.Internal.Data.Fold.Prelude

outputQueueFromConsumer :: Channel m a b -> IORef ([ChildEvent b], Int)

streamly Streamly.Internal.Data.Fold.Prelude

fromConsumer :: MonadAsync m => SVar Stream m a -> m Bool

streamly Streamly.Internal.Data.Stream.SVar

Poll for events sent by the fold consumer to the stream pusher. The fold consumer can send a Stop event or an exception. When a Stop is received this function returns True. If an exception is recieved then it throws the exception.