on master help sign in
Rename chunkParse to parseChunks

chunkParseBreak to parseBreakChunks To make it consistent with other chunked operations that use "chunks" as suffix.

commitd6162588a9ed530b4e24865cbd198156c7734b98 authorHarendra Kumar <harendra@composewell.com> dateSat 18 Feb 2023, 20:06 (4 years ago) parent2d18f9e
3 files changed+12−12
benchmark/Streamly/Benchmark/Data/Parser/ParserK.hs+2−2 core/src/Streamly/Data/Stream/StreamK.hs+2−2 core/src/Streamly/Internal/Data/Stream/StreamK.hs+8−8
benchmark/Streamly/Benchmark/Data/Parser/ParserK.hs+2−2
@@ -68,12 +68,12 @@ benchIOSink value name f =
6868-- Parsers
6969-------------------------------------------------------------------------------
7070
71−#define PARSE_OP StreamK.chunkParse
71+#define PARSE_OP StreamK.parseChunks
7272
7373{-# INLINE one #-}
7474one :: MonadIO m =>
7575 Int -> StreamK m (Array Int) -> m (Either ParseError (Maybe Int))
76−one value = StreamK.chunkParse p
76+one value = StreamK.parseChunks p
7777
7878 where
7979
core/src/Streamly/Data/Stream/StreamK.hs+2−2
@@ -53,8 +53,8 @@ module Streamly.Data.Stream.StreamK
5353
5454 -- ** Parsing
5555 -- , parseBreak
56− , chunkParseBreak
57− -- , chunkParse
56+ , parseBreakChunks
57+ , parseChunks
5858
5959 -- * Combining Two Streams
6060 -- ** Appending
core/src/Streamly/Internal/Data/Stream/StreamK.hs+8−8
@@ -119,8 +119,8 @@ module Streamly.Internal.Data.Stream.StreamK
119119 , foldConcat
120120 , parseDBreak
121121 , parseD
122− , chunkParseBreak
123− , chunkParse
122+ , parseBreakChunks
123+ , parseChunks
124124
125125 -- ** Specialized Folds
126126 , drain
@@ -1280,13 +1280,13 @@ parserDone (ParserK.Success n b) _ _ = pure $ ParserK.Done n b
12801280parserDone (ParserK.Failure n e) _ _ = pure $ ParserK.Error n e
12811281
12821282-- | Run a 'ParserK' over a chunked 'StreamK' and return the rest of the Stream.
1283−{-# INLINE_NORMAL chunkParseBreak #-}
1284−chunkParseBreak
1283+{-# INLINE_NORMAL parseBreakChunks #-}
1284+parseBreakChunks
12851285 :: (Monad m, Unbox a)
12861286 => ParserK.Parser a m b
12871287 -> StreamK m (Array a)
12881288 -> m (Either ParseError b, StreamK m (Array a))
1289−chunkParseBreak parser input = do
1289+parseBreakChunks parser input = do
12901290 let parserk = ParserK.runParser parser parserDone 0 0
12911291 in go [] parserk input
12921292
@@ -1371,10 +1371,10 @@ chunkParseBreak parser input = do
13711371 in foldStream
13721372 defState (yieldk backBuf parserk) single stop stream
13731373
1374−{-# INLINE chunkParse #-}
1375−chunkParse :: (Monad m, Unbox a) =>
1374+{-# INLINE parseChunks #-}
1375+parseChunks :: (Monad m, Unbox a) =>
13761376 ParserK.Parser a m b -> Stream m (Array a) -> m (Either ParseError b)
1377−chunkParse f = fmap fst . chunkParseBreak f
1377+parseChunks f = fmap fst . parseBreakChunks f
13781378
13791379-------------------------------------------------------------------------------
13801380-- Sorting