git.iko.soy/streamly
on master help sign in
Rename chunkParse to parseChunks
d616258Harendra Kumar
benchmark/Streamly/Benchmark/Data/Parser/ParserK.hs+2−2
compare with master
unifiedsplit
@@ -68,12 +68,12 @@ benchIOSink value name f =
68-- Parsers
68-- Parsers
69-------------------------------------------------------------------------------
69-------------------------------------------------------------------------------
70
70
71−#define PARSE_OP StreamK.chunkParse
71+#define PARSE_OP StreamK.parseChunks
72
72
73{-# INLINE one #-}
73{-# INLINE one #-}
74one :: MonadIO m =>
74one :: MonadIO m =>
75 Int -> StreamK m (Array Int) -> m (Either ParseError (Maybe Int))
75 Int -> StreamK m (Array Int) -> m (Either ParseError (Maybe Int))
76−one value = StreamK.chunkParse p
76+one value = StreamK.parseChunks p
77
77
78 where
78 where
79
79
core/src/Streamly/Data/Stream/StreamK.hs+2−2
@@ -53,8 +53,8 @@ module Streamly.Data.Stream.StreamK
53
53
54 -- ** Parsing
54 -- ** Parsing
55 -- , parseBreak
55 -- , parseBreak
56− , chunkParseBreak
56+ , parseBreakChunks
57− -- , chunkParse
57+ , parseChunks
58
58
59 -- * Combining Two Streams
59 -- * Combining Two Streams
60 -- ** Appending
60 -- ** Appending
core/src/Streamly/Internal/Data/Stream/StreamK.hs+8−8
@@ -119,8 +119,8 @@ module Streamly.Internal.Data.Stream.StreamK
119 , foldConcat
119 , foldConcat
120 , parseDBreak
120 , parseDBreak
121 , parseD
121 , parseD
122− , chunkParseBreak
122+ , parseBreakChunks
123− , chunkParse
123+ , parseChunks
124
124
125 -- ** Specialized Folds
125 -- ** Specialized Folds
126 , drain
126 , drain
@@ -1280,13 +1280,13 @@ parserDone (ParserK.Success n b) _ _ = pure $ ParserK.Done n b
1280parserDone (ParserK.Failure n e) _ _ = pure $ ParserK.Error n e
1280parserDone (ParserK.Failure n e) _ _ = pure $ ParserK.Error n e
1281
1281
1282-- | Run a 'ParserK' over a chunked 'StreamK' and return the rest of the Stream.
1282-- | Run a 'ParserK' over a chunked 'StreamK' and return the rest of the Stream.
1283−{-# INLINE_NORMAL chunkParseBreak #-}
1283+{-# INLINE_NORMAL parseBreakChunks #-}
1284−chunkParseBreak
1284+parseBreakChunks
1285 :: (Monad m, Unbox a)
1285 :: (Monad m, Unbox a)
1286 => ParserK.Parser a m b
1286 => ParserK.Parser a m b
1287 -> StreamK m (Array a)
1287 -> StreamK m (Array a)
1288 -> m (Either ParseError b, StreamK m (Array a))
1288 -> m (Either ParseError b, StreamK m (Array a))
1289−chunkParseBreak parser input = do
1289+parseBreakChunks parser input = do
1290 let parserk = ParserK.runParser parser parserDone 0 0
1290 let parserk = ParserK.runParser parser parserDone 0 0
1291 in go [] parserk input
1291 in go [] parserk input
1292
1292
@@ -1371,10 +1371,10 @@ chunkParseBreak parser input = do
1371 in foldStream
1371 in foldStream
1372 defState (yieldk backBuf parserk) single stop stream
1372 defState (yieldk backBuf parserk) single stop stream
1373
1373
1374−{-# INLINE chunkParse #-}
1374+{-# INLINE parseChunks #-}
1375−chunkParse :: (Monad m, Unbox a) =>
1375+parseChunks :: (Monad m, Unbox a) =>
1376 ParserK.Parser a m b -> Stream m (Array a) -> m (Either ParseError b)
1376 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
1378
1378
1379-------------------------------------------------------------------------------
1379-------------------------------------------------------------------------------
1380-- Sorting
1380-- Sorting