on c175cdd help sign in
all commits
2ba5f01rename unstream et. al. and make them polymorphicHarendra Kumar 315abcfFix some state sharing/clearing safety issuesHarendra Kumar e810658Fix monadic state capture and restore for concurrent tasksHarendra Kumar 8b8fd22satisfy hlint (pragmas, imports, <> instead of ++)Harendra Kumar 38aa5f2Refactor code, add asserts, better test outputHarendra Kumar 1f72b61Add inspectMode combinatorHarendra Kumar 49542d2Fix ahead style nil stream merging live lockHarendra Kumar 6c9d241ran src through hlint, made most changes; added .hlint.yaml.Keith 4100822update READMEHarendra Kumar cca869fFix a rate control issueHarendra Kumar e583f56remove heap delayed output checkHarendra Kumar 9d08a58Disringuish the heap clearing and waiting statesHarendra Kumar 3020130refactor to use IORef and MVar interchangeablyHarendra Kumar 477a6deahead stream: do not send extra workersHarendra Kumar 2eec2cddo not send more than on worker to clear the heapHarendra Kumar d73041cPass WorkerInfo only when neededHarendra Kumar bf47e46remove adjustLatencies, account consumer idle time tooHarendra Kumar ebdfa83implement rateBuffer to forget distant gains/lossesHarendra Kumar 482b971make custom rate combinators functionsHarendra Kumar 4a546a8Fix the min/max limit, swapped themHarendra Kumar aa8345dAdd avg/min/max/const/rate specifications for rateHarendra Kumar 904de16refactor some of the yieldRate stuffHarendra Kumar 5d84fb3make NanoSecs Int64 instead of Word64Harendra Kumar 526f024report latency stats for parallel streams as wellHarendra Kumar 59f9158report SVar creator thread and latencies in diagHarendra Kumar c9aecb3Fix some issues in yield limit handling for aheadlyHarendra Kumar 9e55dd7Change yield limit type to Int64 instead of Word64Harendra Kumar adab08dcleanup parallel yield limit codeHarendra Kumar 05ca066Add GC based cleanup of SVarsHarendra Kumar 2c0a6fbcancel parallel tasks when take completesHarendra Kumar 9617a71Show latency stats in diagnostics modeHarendra Kumar 9346144print stats on garbage collectionHarendra Kumar c602d84Fix "not sufficient concurrency" in ahead streamsHarendra Kumar b33e9c2performance improvements after maxrate changesHarendra Kumar 610c33aAdd concurrency rate control using maxRateHarendra Kumar cf87d11implement maxYields to put a limit on total yields of a streamHarendra Kumar 72766cbrename threads to maxThreads and buffer to maxBufferHarendra Kumar 211df79Add concurrency control using "threads" and "buffer"Harendra Kumar 4b05cb4split SVar specific code into a separate fileHarendra Kumar