on 5592064 help sign in
all commits
98b4fc3clear the finalizer from IORef on exceptionHarendra Kumar 753d091Refactor currentTime, add comments, safety notesHarendra Kumar 5054813Add currentTime and its benchmarksadithyaov a67e688Use StreamD version of mergeBy in async mergeHarendra Kumar a285b55Change mkParallel and mkAsync signaturesHarendra Kumar b8178cdFix copyright metadata in some modules.Pranay Sashank 60cee48Add exception handling combinators with guaranteed cleanupHarendra Kumar 290d2f6Make some updates to takeByTime/dropByTimeHarendra Kumar 1979370Add takeByTime and dropByTime combinatorsadithyaov 5faf292Mv bemchmarks & change INLINABLE to INLINE - lastNadithyaov 5aa8e44Add tests to lastNadithyaov 46643d1Add lastN combinatoradithyaov b83c2c2Add tapOffsetEvery to tap one in n elementsHarendra Kumar 5073377Add modular stream stats countingHarendra Kumar 135063fuse Prim Var instead of IORefHarendra Kumar 4374014Add fromPrimVar - generate a stream from a Prim VarHarendra Kumar 511fe85Use StreamD for iterate and iterateMadithyaov d582037Add tapRate combinator.Pranay Sashank d229a4bimplement StreamD style tapAsync for fusionHarendra Kumar 634df53Move encodeUtf8/decodeUtf8 implementation from StreamD module.Pranay Sashank d6c883cSeq accumulator in tap.Pranay Sashank 8bf7eedInclude src in scope to use #include "inline.hs"adithyaov 4172ad9Move inline.hs to top level, src/inline.hsadithyaov 70c03f9Move Streams/StreamK* to Internal/Data/Streamadithyaov 59796f1Move Streams/StreamD.hs to Internal/Data/Stream/*adithyaov