Fast, safe and composable streaming abstractions.
Streaming abstractions that combine, transform and reduce large amounts of sequential data efficiently, in constant space and without leaking resources.
Streaming uses composable stream producers (sources), consumers (sinks) and
transformers (flows). The central model that abstracts over them is a Stream
.
The following features are provided:
Read the library documenation for more details.
This library is based on ideas found in other libraries and research projects such as: Haskell's Pipes and Foldl libraries, Scala's ZIO Streams, Clojure's Transducers and the Iteratees streaming model by Oleg Kiselyov.