git.iko.soy/streamly
on 103705f help sign in
history ofsrc/Streamly/Streams/Parallel.hs
all commits
631cc24move file SVar.hs to Internal/DataHarendra Kumar 307fa9fAdd direct style append/interleave/concatUnfoldInterleave etcHarendra Kumar 7c9c1c4Add support for GHC 8.8Harendra Kumar f0f0c8bFix "thread blocked indefinitely in an MVar operationHarendra Kumar 7e853faExpose tapAsync via internal moduleHarendra Kumar fbb627dupdate documentation for maxBuffer changes for ParallelTHarendra Kumar 39fcfd9Add some TODO commentsHarendra Kumar 8a4d965Add trace, tap and tee combinatorsHarendra Kumar cecad7eProvide a different impl for yieldLimit caseHarendra Kumar debe277Do not run each individual stream action with captured stateHarendra Kumar 90161e1Apply static argument transformation to runOneHarendra Kumar ed7f4abImplement bounded buffering for ParallelT streamsHarendra Kumar 68d2bf8Add parallel stream stop stylesHarendra Kumar 1949eb9Concurrent concatMap, foldr/build fusion, benchmarksHarendra Kumar fd7bd71Add "Streamly.Fold" moduleHarendra Kumar d01942dAdd applicative benchmarksHarendra Kumar ede29dfspecialize the typeclass instances to recover performanceHarendra Kumar 0a2755aChange the order of foldStream argumentsHarendra Kumar 2ba5f01rename unstream et. al. and make them polymorphicHarendra Kumar 315abcfFix some state sharing/clearing safety issuesHarendra Kumar 924856bMake the default unStream safe, #96.Pranay Sashank 11d8d6dFix foldable/traversable instancesHarendra Kumar 159a0d2Derive Foldable and Traversable instance for all the newtype wrappers around streamsAbhiroop Sarkar a615989Do not fully saturate the type synonymsHarendra Kumar e810658Fix monadic state capture and restore for concurrent tasksHarendra Kumar 8b8fd22satisfy hlint (pragmas, imports, <> instead of ++)Harendra Kumar 6c9d241ran src through hlint, made most changes; added .hlint.yaml.Keith d73041cPass WorkerInfo only when neededHarendra Kumar 772dbd4replace "once" with "yieldM" in examplesHarendra Kumar e2c366cAllow state passing through stream append operationsHarendra Kumar 526f024report latency stats for parallel streams as wellHarendra Kumar adab08dcleanup parallel yield limit codeHarendra Kumar 2c0a6fbcancel parallel tasks when take completesHarendra Kumar 610c33aAdd concurrency rate control using maxRateHarendra Kumar cd50805Do not share concurrency state in concurrent function applicationHarendra Kumar cf87d11implement maxYields to put a limit on total yields of a streamHarendra Kumar 211df79Add concurrency control using "threads" and "buffer"Harendra Kumar 3ae9530use folds and map from direct style streamHarendra Kumar 9c85811rename "once" to "yieldM"Harendra Kumar 5ee02ffrename the continuation based stream to StreamKHarendra Kumar 8830c32Split Streams.hs into individual stream type filesHarendra Kumar