@@ -41,39 +41,39 @@ main = do
4141 [ bench "function style all serial" $ nfIO streamly_function_style
4242
4343 , bgroup "serial bind"
44− [ bench "serial" $ nfIO (as (A.<>))
45− , bench "fair serial" $ nfIO (as (A.<=>))
46− , bench "left parallel" $ nfIO (as (A.<|))
47− , bench "fair parallel" $ nfIO (as (A.<|>))
44+ [ bench "serial" $ nfIO (as (A.append))
45+ , bench "fair serial" $ nfIO (as (A.interleave))
46+ , bench "left parallel" $ nfIO (as (A.asyncmerge))
47+ , bench "fair parallel" $ nfIO (as (A.parmerge))
4848 ]
4949
5050 , bgroup "interleaved bind"
51− [ bench "serial" $ nfIO (ai (A.<>))
52− , bench "fair serial" $ nfIO (ai (A.<=>))
53− , bench "left parallel" $ nfIO (ai (A.<|))
54− , bench "fair parallel" $ nfIO (ai (A.<|>))
51+ [ bench "serial" $ nfIO (ai (A.append))
52+ , bench "fair serial" $ nfIO (ai (A.interleave))
53+ , bench "left parallel" $ nfIO (ai (A.asyncmerge))
54+ , bench "fair parallel" $ nfIO (ai (A.parmerge))
5555 ]
5656
5757 , bgroup "async bind"
58− [ bench "serial" $ nfIO (aa (A.<>))
59− , bench "fair serial" $ nfIO (aa (A.<=>))
60− , bench "left parallel" $ nfIO (aa (A.<|))
61− , bench "fair parallel" $ nfIO (aa (A.<|>))
58+ [ bench "serial" $ nfIO (aa (A.append))
59+ , bench "fair serial" $ nfIO (aa (A.interleave))
60+ , bench "left parallel" $ nfIO (aa (A.asyncmerge))
61+ , bench "fair parallel" $ nfIO (aa (A.parmerge))
6262 ]
6363
6464 , bgroup "parallel bind"
65− [ bench "serial" $ nfIO (ap (A.<>))
66− , bench "fair serial" $ nfIO (ap (A.<=>))
67− , bench "left parallel" $ nfIO (ap (A.<|))
68− , bench "fair parallel" $ nfIO (ap (A.<|>))
65+ [ bench "serial" $ nfIO (ap (A.append))
66+ , bench "fair serial" $ nfIO (ap (A.interleave))
67+ , bench "left parallel" $ nfIO (ap (A.asyncmerge))
68+ , bench "fair parallel" $ nfIO (ap (A.parmerge))
6969 ]
7070
7171 -- Benchmark smallest possible actions composed together
7272 , bgroup "serial bind nil"
73− [ bench "serial" $ nfIO (streamly_nil (A.<>))
74− , bench "fair serial" $ nfIO (streamly_nil (A.<=>))
75− , bench "left parallel" $ nfIO (streamly_nil (A.<|))
76− , bench "fair parallel" $ nfIO (streamly_nil (A.<|>))
73+ [ bench "serial" $ nfIO (streamly_nil (A.append))
74+ , bench "fair serial" $ nfIO (streamly_nil (A.interleave))
75+ , bench "left parallel" $ nfIO (streamly_nil (A.asyncmerge))
76+ , bench "fair parallel" $ nfIO (streamly_nil (A.parmerge))
7777 ]
7878 ]
7979#ifdef EXTRA_BENCHMARKS