a00e057 · streamly · git.iko.soy

git.iko.soy/streamly

on master help sign in

Add benchmark for tapAsync

a00e057Harendra Kumar7 years ago

benchmark/Linear.hs+1

@@ -319,6 +319,7 @@ main =

319 , benchIOSink "foldrT" (Ops.foldrT 1)

320 , benchIOSink "foldrTMap" (Ops.foldrTMap 1)

321 , benchIOSink "tap" (Ops.tap 1)

322+ , benchIOSink "tapAsync" (Ops.tapAsync 1)

322 , benchIOSink "tapAsyncS" (Ops.tapAsyncS 1)

323 , benchIOSink "tapAsyncS" (Ops.tapAsyncS 1)

323 ]

324 ]

324 , bgroup "transformationX4"

325 , bgroup "transformationX4"

benchmark/Streamly/Benchmark/Prelude.hs+4

@@ -444,6 +444,10 @@ tap n = composeN n $ S.tap FL.sum

444tapAsyncS :: S.MonadAsync m => Int -> Stream m Int -> m ()

445tapAsyncS n = composeN n $ Par.tapAsync S.sum

446

447+{-# INLINE tapAsync #-}

448+tapAsync :: S.MonadAsync m => Int -> Stream m Int -> m ()

449+tapAsync n = composeN n $ Internal.tapAsync FL.sum

450+

447{-# INLINE transformMapM #-}

451{-# INLINE transformMapM #-}

448{-# INLINE transformComposeMapM #-}

452{-# INLINE transformComposeMapM #-}

449{-# INLINE transformTeeMapM #-}

453{-# INLINE transformTeeMapM #-}