streamly
streamly copied to clipboard
composewell
High performance, concurrent functional programming abstractions
From: ``` demux :: (Monad m, Ord k) => (a -> k) -> (a -> m (Fold m a b)) -> Fold m a (m (Map k b), Maybe (k,...
If an immutable array is a slice over a bigger array, only then, we can copy out the slice into a new array. This is an alternative for the `clone`...
Following `Set` based APIs can be added in `Streamly.Internal.Data.Stream.Container`: ``` , ordIntersectBy , ordDeleteFirstsBy , ordUnionBy ```
Some of the [base/Data.List](https://hackage.haskell.org/package/base-4.10.1.0/docs/Data-List.html) operations that are missing and we can add to Streamly. These operations are fairly easy or in some cases trivial or mechanical to implement. They can...
That is stop without returning a value and get the value by using `final`. We need "Done b" in folds instead of "Stop" to know the termination without having to...
To make the conversions more concise we can shorten them something like the following, we can even import these unqualified: ``` StreamK.fromStream => sK ParserK.adapt => pK ``` Other alternatives...
In streams we have two way conversion StreamK.fromStream and StreamK.toStream but parsers have only one way ParserK.adapt. We could possibly remove StreamK.toStream if there are no sensible use cases for...
Metadata
Owner
Metadata
High performance, concurrent functional programming abstractions