@@ -126,18 +126,32 @@ main = do
126126 , bgroup "asyncly"
127127 [ -- benchIO "unfoldr" $ Ops.toNull asyncly
128128 benchSrcIO asyncly "unfoldrM" Ops.sourceUnfoldrM
129− , benchSrcIO asyncly "unfoldrM maxThreads 1"
130− (maxThreads 1 . Ops.sourceUnfoldrM)
131− -- XXX arbitrarily large maxRate should be the same as maxRate -1
132− , benchSrcIO asyncly "unfoldrM rate AvgRate 1000000"
133− (avgRate 1000000 . Ops.sourceUnfoldrM)
134− , benchSrcIO asyncly "unfoldrM maxBuffer 1 (1000 ops)"
135− (maxBuffer 1 . Ops.sourceUnfoldrMN 1000)
136129 -- , benchSrcIO asyncly "fromFoldable" Ops.sourceFromFoldable
137130 , benchSrcIO asyncly "fromFoldableM" Ops.sourceFromFoldableM
138131 -- , benchSrcIO asyncly "foldMapWith" Ops.sourceFoldMapWith
139132 , benchSrcIO asyncly "foldMapWithM" Ops.sourceFoldMapWithM
140133 , benchIO "mapM" $ Ops.mapM asyncly
134+ , benchSrcIO asyncly "unfoldrM maxThreads 1"
135+ (maxThreads 1 . Ops.sourceUnfoldrM)
136+ , benchSrcIO asyncly "unfoldrM maxBuffer 1 (1000 ops)"
137+ (maxBuffer 1 . Ops.sourceUnfoldrMN 1000)
138+ ]
139+ , bgroup "asyncly/rate"
140+ [ -- benchIO "unfoldr" $ Ops.toNull asyncly
141+ benchSrcIO asyncly "unfoldrM" Ops.sourceUnfoldrM
142+ , benchSrcIO asyncly "unfoldrM/Nothing"
143+ (rate Nothing . Ops.sourceUnfoldrM)
144+ , benchSrcIO asyncly "unfoldrM/AvgRate/1,000,000"
145+ (avgRate 1000000 . Ops.sourceUnfoldrM)
146+ , benchSrcIO asyncly "unfoldrM/AvgRate/3,000,000"
147+ (avgRate 3000000 . Ops.sourceUnfoldrM)
148+ , benchSrcIO asyncly "unfoldrM/AvgRate/10,000,000/maxThreads1"
149+ (maxThreads 1 . avgRate 10000000 . Ops.sourceUnfoldrM)
150+ -- XXX arbitrarily large rate should be the same as rate Nothing
151+ , benchSrcIO asyncly "unfoldrM/AvgRate/10,000,000"
152+ (avgRate 10000000 . Ops.sourceUnfoldrM)
153+ , benchSrcIO asyncly "unfoldrM/AvgRate/20,000,000"
154+ (avgRate 20000000 . Ops.sourceUnfoldrM)
141155 ]
142156 , bgroup "wAsyncly"
143157 [ -- benchIO "unfoldr" $ Ops.toNull wAsyncly