git.iko.soy/streamly
on 294aa21 help sign in
history ofsrc/Streamly/Internal/Data/Stream/StreamD.hs
all commits
3e22f1bflush sessions when classifySessionsOf endsHarendra Kumar 602539fAdd/change some time/interspersing combinatorsHarendra Kumar 7013f3aFix delayPost, add more interspersing combinatorsHarendra Kumar 7f9d4a4Add some time related combinatorsHarendra Kumar 40d1e64Fix a bug in YieldB caseHarendra Kumar 2c9feb4Add YieldB (yield and backtrack) constructorHarendra Kumar 633c55erename splitParse/parseMany, concatParse/parseIterateHarendra Kumar 684d278Add concatParse to chain parsers on a streamHarendra Kumar dde9041Use parserK by default and rewrite to ParserDHarendra Kumar a03e287rename Parser module to ParserDHarendra Kumar 202c33dAdd Alternative instance, combinators and parsersHarendra Kumar f6327e5Use exceptions instead of Either return in extractHarendra Kumar b438129Fix -Wunused-record-wildcards warnings.Pranay Sashank ab541b4specialize the "Skip 0" case in "parse"Harendra Kumar f1eb9a1rename parseChunks to splitParseHarendra Kumar 136bf79Rename Parse type and Step constructorsHarendra Kumar cc8cd01Simplify the Parse typeHarendra Kumar 2723c15Implement stream parsingHarendra Kumar c5d0871Added comments.Shlok Datye 8f4f9edMask async exceptions in the "bracketIO" functions.Shlok Datye 8766fbfAdd concatM and fromCallbackHarendra Kumar 59509cdFix lastN for n <= 0adithyaov 54662d8Add a predicate to pollCountsHarendra Kumar 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