streamly

streamly copied to clipboard

harendra-kumar

harendra-kumar

The recursive directory listing APIs are inefficient as they list each directory and then use the produced paths to try to list the children. Instead we can use the inodes...

harendra-kumar

zipWith may be confused with zipping outputs rather than inputs.

harendra-kumar

Make it pollTap: ``` pollCounts :: (MonadAsync m) => Fold m a Int -> (Stream m Int -> m b) -> Stream m a -> Stream m a ``` Currently...

harendra-kumar

- [ ] Streamly.Internal.Data.SVar.Worker - [ ] Streamly.Internal.Data.SVar.Dispatch - [ ] Streamly.Internal.Data.SVar.Pull - [ ] Streamly.Internal.Data.SVar - [ ] Streamly.Internal.Data.Unfold.SVar - [ ] Streamly.Internal.Data.Fold.SVar - [ ] Streamly.Internal.Data.Fold.Async - [...

adithyaov

harendra-kumar

Generalized representation of a sliding window

3

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...

harendra-kumar

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...

harendra-kumar

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...

harendra-kumar