git.iko.soy/streamly
on 064bb7e help sign in
064bb7eSome simplificationsHarendra Kumar bdaefb3Reuse threads instead of creating fresh every timeHarendra Kumar e8a7463Use TBQueue instead of an unbounded channelHarendra Kumar b3faafaSolve the problem of last dispatch blocking drainHarendra Kumar 2248afaSimplify runner functionsHarendra Kumar ab91267Add test case for hierarchical alternative compositionHarendra Kumar 5181c0dFix warning in benchmarkHarendra Kumar 1f01190Fix bug due to typo in pull finalizer and move itHarendra Kumar a61b30bFix, delete, move examplesHarendra Kumar 02a745fupdate examples READMEHarendra Kumar 7beefceFix examplesHarendra Kumar b68840bAdd some more examplesHarendra Kumar 5349a44update some examplesHarendra Kumar d8c399eImplement tracking and killing of child threadsHarendra Kumar 36ecdf8Perf - do not save pending work in the contextHarendra Kumar 6ec80a0Fix draining of threads (serial instead of parallel)Harendra Kumar 04fef4fMove a function in dep orderHarendra Kumar 09283c4Implement pull based concurrency rate controlHarendra Kumar b1ee90eAdd the yield APIHarendra Kumar 500d889Simplify push-pull split, fix monoid instanceHarendra Kumar b2faaf9remove a couple of stale commentsHarendra Kumar b38be3aReduce channel communication for short tasksHarendra Kumar 91a6ceeSimplify pushHarendra Kumar 9b2ca30Add the "for" parallel API and change "each" to serialHarendra Kumar 63f965acleanup Monoid instanceHarendra Kumar 6ea73b3Cleanup and refactor threading stuffHarendra Kumar e874ecfRemove quadratic complexity due to serially-in-seriallyHarendra Kumar 8a1d5d9Add a test for "each" to test multiple threadsHarendra Kumar 550eed4Make monoid instance append two computations in orderHarendra Kumar ef006c8Implement fork for Alternative instanceHarendra Kumar 9f7d672Simplify toList runnerHarendra Kumar c9b9ab3Pass context directly, removing the use of State monadHarendra Kumar 6935930Add list-t to benchmarksHarendra Kumar f4cce2fSeparate the bind and <|> semantics for parallelismHarendra Kumar 7b52ccfPartially fix the recording stuffHarendra Kumar f8851aaAdd MonadRecorder instance to AsynclyTHarendra Kumar 4f3775dEnable threads API and testsHarendra Kumar 17b30barename the runner APIsHarendra Kumar 504800bMore cleanup in RunAsyncHarendra Kumar bb5a74dSome cleanupsHarendra Kumar eca7d81Remove redundant composition primitivesHarendra Kumar a20c180Some cleanupHarendra Kumar 99d9ba6Fix the composite benchmark codeHarendra Kumar c1f0a86Continuation based implementationHarendra Kumar 7e8209eSeparate the State layer from AsyncT layerHarendra Kumar 4d7024fInitial poc of lazy streamingHarendra Kumar 11c1f14Add some simple testsHarendra Kumar c49732aMove the each primitive to right placeHarendra Kumar cc4743cAdd machine benchmark and fix othersHarendra Kumar 4d4894cMove the thread contol primitive to threads moduleHarendra Kumar