Harendra Kumar
Harendra Kumar
In this case the pending threads are cleaned up by the GC. You can try running it like this and you will get the expected results: ``` {-# LANGUAGE ScopedTypeVariables...
@TheKK thanks for following up on this. We are fixing it in 0.11. There are two issues here: * Cleanup leaks threads when eager option is used, due to a...
Fixed by #3038 .
streamly on hackage now supports ghc 9.10 and 9.12 .
When we dispatch concurrent workers, stagger them over a period instead of starting all of them in a burst. This will regulate the workload more smoothly e.g. when we are...
For `ahead` style streams, for the test "aheadly no consumer delay and 1 sec producer delay" we can only achieve half the rate compared to `async` style streams. Need to...
@alexanderkjeldaas https://en.wikipedia.org/wiki/Kalman_filter looks interesting. Will have to see if and how we can apply it to our situation.
We are going to use the name "trace" for user level stream tracing APIs, see #103 . This particular issues in the "inspection" domain i.e. inspecting the internal/meta details of...
Please take a look at [this example](https://github.com/composewell/streamly/blob/96f01fd13463d03c4586104954d266791605bb5c/examples/ListDir.hs). This example traverses the directory tree concurrently: ``` let stream = S.concatMapTreeWith ahead listDir (S.yieldM $ return (Left ".")) ``` The above snippet...
> Then what is "the element" of "a stream"? Not sure I understand the question fully. A stream is a sequence of actions each of which results in an output...