composewell/streamly
1
1
Fork 0
mirror of https://github.com/composewell/streamly.git synced 2024-09-11 19:47:10 +03:00
Code Issues Packages Projects Releases Wiki Activity

Fix old prelude rate benchmarks

Browse Source
This commit is contained in:
Harendra Kumar 2024-02-15 08:16:51 +05:30
parent 0990626371
commit b2e7d1dabc
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
benchmark/lib/Streamly/Benchmark/Prelude.hs
View File

@ -62,7 +62,7 @@ module Streamly.Benchmark.Prelude
, transformComposeMapM
, transformMapM
, transformTeeMapM
, transformZipMapM
-- , transformZipMapM
)
where
@ -78,7 +78,7 @@ import qualified Data.Foldable as F
import qualified Data.List as List
import qualified Streamly.Prelude as S
import qualified Streamly.Internal.Data.Stream.IsStream as Internal
import qualified Streamly.Internal.Data.Stream.IsStream.Type as IsStream
import qualified Streamly.Internal.Data.Stream.IsStream as IsStream
import qualified Streamly.Internal.Data.Pipe as Pipe
import qualified Streamly.Internal.Data.Stream.Serial as Serial
@ -318,9 +318,10 @@ transformTeeMapM t n =
composeN n $
t .
Internal.transform
(Pipe.mapM (\x -> return (x + 1)) `Pipe.tee`
(Pipe.mapM (\x -> return (x + 1)) `Pipe.teeMerge`
Pipe.mapM (\x -> return (x + 2)))
{-
{-# INLINE transformZipMapM #-}
transformZipMapM ::
(S.IsStream t, S.MonadAsync m)
@ -336,6 +337,7 @@ transformZipMapM t n =
(+)
(Pipe.mapM (\x -> return (x + 1)))
(Pipe.mapM (\x -> return (x + 2))))
-}
-------------------------------------------------------------------------------
-- Streams of streams