Harendra Kumar
Harendra Kumar
Commit 211df792a49d8d39603d5fb3e7f48a8169c91c8d introduced a state being passed through the stream, always. We can use this to implement a `trace` command just like `threads` and `buffer` commands. The trace API can...
When "eager" is not used the reading of buffer from the channel is interleaved with worker dispatch. However, when "eager" is used there is no worker dispatch to be done...
Need to expose maxYields from the Internal module and test it.
All the tests from `test/Streamly/Test/Prelude/*` should be ported to test the new concurrent stream module.
Consider the directory traversal code using parConcatIterate, the workers produce `Left dirs` and `Right files`. The workers need not produce `Left dirs` and can continue consuming those themselves unless there...
`streamly-benchmarks` is an independent package and can use these two packages for convenience in some cases. The recursive directory listing benchmarks create directory tree using a shell script, it can...
For the Unbox type class we have Peeker monad. It could use the `Array` or `MutArray` type instead of `BoundedPtr`. Similarly, we can write a Poker monad which can use...
Not present in: * https://www.stackage.org/lts-23.9 * https://www.stackage.org/nightly-2025-02-16
For example, the ListDir C equivalent program needs a toByteArray API.
Using ST we can use thread specific mutable state, and ST can be converted to IO using `RealWorld`.