streamly
streamly copied to clipboard
High performance, concurrent functional programming abstractions
So that the chunks could be of specific array type e.g. Array or MutArray. Deprecate/remove it from the Data.Stream module.
**Data.Stream.Concurrent, maxThreads 1, constructWithCons** uncaught exception: ErrorCall Prelude.undefined CallStack (from HasCallStack): error, called at libraries/base/GHC/Err.hs:74:14 in base:GHC.Err undefined, called at src/Streamly/Internal/Data/Stream/Concurrent/Channel/Append.hs:114:21 in streamly-0.10.0-inplace:Streamly.Internal.Data.Stream.Concurrent.Channel.Append (after 1 test) **Data.Stream.Concurrent.ordered constructWithCons** uncaught exception:...
Generic takes 256 constructors max, TH can do more. We should use variable length encoding for constructor tags in TH and limit the generic constructors to 128 with encoding compatible...
In `ParserD` the `Int` in step indicates the amount of elements to backtrack. - `Partial 3 a` means go back by 3 elements before running the driver again. - `Partial...
fromRational is very expensive, need to see if it can be improved: https://hackage.haskell.org/package/base-4.18.0.0/docs/src/GHC.Float.html#fromRat%27%27
resourcet package can be used with streamly-core. With `streamly` package it would require unliftio instead of monad-control which is only implemented under an experimental flag as of now. Pasting some...
Use streamly idioms to implement a few megaparsec combinators. The following to begin with. - takeRest - atEnd - match In doc, we can write about using parser-combinators with some...
If we do not support slicing and expandability we do not need a separate handle for the array, this can reduce an indirection and improve perf in some cases. When...
See https://github.com/composewell/streamly/commit/9efd2b211cb926dfd2236cb1867b8d96d5b09ff0 `Data.Parser.ParserK/o-n-heap/sequenceA` in `bench:Data.Parser.ParserK` fails with `Segmentation fault (core dumped)`