Harendra Kumar
Harendra Kumar
If we generate the streams using unfolds and use those streams in multi-stream operations e.g. isSubsequenceOf then the operation does not fuse, however, if we use the direct implementation of...
See #1709 . 1709 is about some multi-stream operations not fusing. Some other multi-stream operations like eqBy do fuse for unfolds but are CPU inefficient compared to the case when...
Like we deal with config in fsnotify modules.
* Records * Effects * Logging ---- - [x] Break into smaller packages to make the packaging modular - [ ] GHC proposal to integrate fusion-plugin functionality - [x] Monomorphic...
After #1678 we are using the name "Storable" but it is aliased to "Prim" which would be confusing. We should either use a more abstract name "Unboxed" or use the...
We need to just copy the Benchmark.Prelude.Serial.* modules to Benchmark.Data.Stream.* . Need to make a one-to-one correspondence of benchmark modules to the source modules.
For `MonadTrans` instance we will need the types to be `Unfold a m b` and `Fold a m b` but then we will need a newtype for `Category` /`Arrow`/`Profunctor` instances....
There are tests in PR #912 that can be used for array-stream-folds (PR #1034). We should also add some benchmarks similar to the streamly-lz4 or tar cases that are the...
We should have functionality equivalent to `Data.Array.Foreign` and plan to expose this module. For example, there is no `getIndex` API in this module which makes it a non-starter as an...
Make ring buffer a first class streaming citizen by providing read unfold and write fold for it just like array. That will enable us to use ringbuffers more e.g. `lastN`...