streamly
streamly copied to clipboard
High performance, concurrent functional programming abstractions
Even though it would be redundant, it may be convenient to have - for example, `Stream.drain = Stream.fold Fold.drain`.
I am trying to create a function that would modify the _last_ element of the stream. I came up with the following solution using `uncons`: ```haskell -- | Increment the...
A typical example of multi-layer operations is concat with similar semantics as the list `concat` operation [here](https://hackage.haskell.org/package/base-4.10.1.0/docs/Data-List.html#g:4). Streaming/Pipes/Machines concat a `Foldable` whereas Conduit concats a `MonoFoldable` which includes monomorphic containers...
We need to create a separate package(s) for this. We can support different types of compression decompression in the same package using different modules or in separate packages. Some related...
Either a preferred approach to be used with streamly should be documented or any built-in support required should be provided. The stream tracing operations can potentially be adapted into similar...
We deal with two sequencing dimensions user specified ordering of stream and time ordering of stream. For example, the Ahead stream return values in the user specified sequence whereas the...