ebb3059 · streamly · git.iko.soy

git.iko.soy/streamly

Use a special case for "Continue 1" case

In the StreamD parse driver.

commitebb305996a8ad1ba59faa9b5599b27be4cb6da07 authorHarendra Kumar <harendra@composewell.com> dateTue 28 Feb 2023, 08:46 (4 years ago) parent7b52d91

1 file changed+5

unifiedsplit

core/src/Streamly/Internal/Data/Stream/StreamD/Eliminate.hs+5

@@ -219,6 +219,7 @@ parseBreakD (PRD.Parser pstep initial extract) stream@(Stream step state) = do

219219 src = Prelude.reverse src0

220220 gobuf SPEC s (List []) (List src) pst1

221221 PR.Continue 0 pst1 -> go SPEC s (List (x:getList buf)) pst1

222+ PR.Continue 1 pst1 -> gobuf SPEC s buf (List [x]) pst1

222223 PR.Continue n pst1 -> do

223224 assert (n <= length (x:getList buf)) (return ())

224225 let (src0, buf1) = splitAt n (x:getList buf)

@@ -279,6 +280,8 @@ parseBreakD (PRD.Parser pstep initial extract) stream@(Stream step state) = do

279280 gobuf SPEC s (List []) (List src) pst1

280281 PR.Continue 0 pst1 ->

281282 gobuf SPEC s (List (x:getList buf)) (List xs) pst1

283+ PR.Continue 1 pst1 ->

284+ gobuf SPEC s buf (List (x:xs)) pst1

282285 PR.Continue n pst1 -> do

283286 assert (n <= length (x:getList buf)) (return ())

284287 let (src0, buf1) = splitAt n (x:getList buf)

@@ -309,6 +312,8 @@ parseBreakD (PRD.Parser pstep initial extract) stream@(Stream step state) = do

309312 goExtract SPEC (List []) (List src) pst1

310313 PR.Continue 0 pst1 ->

311314 goExtract SPEC (List (x:getList buf)) (List xs) pst1

315+ PR.Continue 1 pst1 ->

316+ goExtract SPEC buf (List (x:xs)) pst1

312317 PR.Continue n pst1 -> do

313318 assert (n <= length (x:getList buf)) (return ())

314319 let (src0, buf1) = splitAt n (x:getList buf)