@@ -153,6 +153,10 @@ takeFramedByEsc_ _ = Stream.parse parser
154 parser = PR.takeFramedByEsc_ isEsc isBegin isEnd Fold.drain
154 parser = PR.takeFramedByEsc_ isEsc isBegin isEnd Fold.drain
157+eqBy :: Int -> Stream IO Int -> IO ()
158+eqBy len = Stream.parse (PR.eqBy (==) [1 .. len])
156{-# INLINE takeWhile #-}
160{-# INLINE takeWhile #-}
157takeWhile :: MonadThrow m => Int -> Stream m Int -> m ()
161takeWhile :: MonadThrow m => Int -> Stream m Int -> m ()
158takeWhile value = Stream.parse (PR.takeWhile (<= value) Fold.drain)
162takeWhile value = Stream.parse (PR.takeWhile (<= value) Fold.drain)
@@ -473,6 +477,7 @@ o_1_space_serial value =
473 , benchIOSink value "concatSequence" concatSequence
477 , benchIOSink value "concatSequence" concatSequence
474 , benchIOSink value "parseMany (groupBy (<))" (parseManyGroupBy (<))
478 , benchIOSink value "parseMany (groupBy (<))" (parseManyGroupBy (<))
475 , benchIOSink value "parseMany (groupBy (==))" (parseManyGroupBy (==))
479 , benchIOSink value "parseMany (groupBy (==))" (parseManyGroupBy (==))
480+ , benchIOSink value "eqBy" (eqBy value)
478o_1_space_filesystem :: BenchEnv -> [Benchmark]
483o_1_space_filesystem :: BenchEnv -> [Benchmark]