@@ -71,6 +71,10 @@ all value = IP.parse (PR.all (<= value))
7171take :: MonadCatch m => Int -> SerialT m a -> m ()
7272take value = IP.parse (PR.take value FL.drain)
7373
74+{-# INLINE takeEQ #-}
75+takeEQ :: MonadCatch m => Int -> SerialT m a -> m ()
76+takeEQ value = IP.parse (PR.takeEQ value FL.drain)
77+
7478{-# INLINE takeWhile #-}
7579takeWhile :: MonadCatch m => Int -> SerialT m Int -> m ()
7680takeWhile value = IP.parse (PR.takeWhile (<= value) FL.drain)
@@ -227,6 +231,7 @@ o_1_space_serial value =
227231 [ benchIOSink value "any" $ any value
228232 , benchIOSink value "all" $ all value
229233 , benchIOSink value "take" $ take value
234+ , benchIOSink value "takeEQ" $ takeEQ value
230235 , benchIOSink value "takeWhile" $ takeWhile value
231236 , benchIOSink value "splitAp" $ splitAp value
232237 , benchIOSink value "splitApBefore" $ splitApBefore value