Harendra Kumar

Generalized representation of a sliding window

4

Currently we are using `(a, Maybe a)` type for a window operation. It allows growing the window using `(a, Nothing)` and sliding the window using `(a, Just a)`. However for...

Currently streams can merge concurrently but folds do not have the capability to run the split streams in different threads concurrently. The `tapAsync` combinator is a first step in that...

Work on the Pipe type

1

From #242 : > A Pipe type to represent composable transformations. The transformations in Streamly.Prelude should be representable using the Pipe type. Also, the contravariant transformations of folds should be...

Move them to the Array module. Also move the adaptC/adaptCG parser adapting functions to the relevant array modules.

``` parList => parConcatList : in line with parConcatMap. sampleIntervalStart => sampleIntervalHead : use noun for `Start` to avoid confusion sampleIntervalEnd => sampleIntervalTail sampleBurstStart => sampleBurstHead sampleBurstEnd => sampleBurstTail ```

Unreproducible test failure

1

First seen at commit 350b6acae : ``` Failures: Streamly/Test/Unicode/Stream.hs:177:9: 1) Unicode.Stream, UTF8 - Encoding / Decoding, Arrays Streamly.Data.String.lines == Prelude.lines Assertion failed (after 584 tests): [111,74,18,114,114,246,44,86,35,209,255,112,6,60,174,59,132,154,226,252,199,212,251,28,42,66,99,32,168,104,253,69,83,11,204,31,196,230,108,29,70,236,204,117,66,71,126,154,46,228,238,157,11,39,251,207,151,177,9,109,64,112,173,11,125,162,19,108,201,110] To rerun use: --match...

Along with this, we will need to add a cycle detection as well.

Use ByteArray# instead of MutableByteArray# in the immutable Array

1

Freeze it before finalizing the array.