@@ -167,18 +167,21 @@ main = do
167 , bgroup "aheadly"
167 , bgroup "aheadly"
168 [ -- benchIO "unfoldr" $ Ops.toNull aheadly
168 [ -- benchIO "unfoldr" $ Ops.toNull aheadly
169 benchSrcIO aheadly "unfoldrM" Ops.sourceUnfoldrM
169 benchSrcIO aheadly "unfoldrM" Ops.sourceUnfoldrM
170+ , benchSrcIO aheadly "fromFoldableM" Ops.sourceFromFoldableM
171+ -- , benchSrcIO aheadly "foldMapWith" Ops.sourceFoldMapWith
172+ , benchSrcIO aheadly "foldMapWithM" Ops.sourceFoldMapWithM
173+ , benchIO "mapM" $ Ops.mapM aheadly
170 , benchSrcIO aheadly "unfoldrM maxThreads 1"
174 , benchSrcIO aheadly "unfoldrM maxThreads 1"
171 (maxThreads 1 . Ops.sourceUnfoldrM)
175 (maxThreads 1 . Ops.sourceUnfoldrM)
172− -- XXX arbitrarily large maxRate should be the same as maxRate -1
173− , benchSrcIO aheadly "unfoldrM rate AvgRate 1000000"
174− (avgRate 1000000 . Ops.sourceUnfoldrM)
175 , benchSrcIO aheadly "unfoldrM maxBuffer 1 (1000 ops)"
176 , benchSrcIO aheadly "unfoldrM maxBuffer 1 (1000 ops)"
176 (maxBuffer 1 . Ops.sourceUnfoldrMN 1000)
177 (maxBuffer 1 . Ops.sourceUnfoldrMN 1000)
177 -- , benchSrcIO aheadly "fromFoldable" Ops.sourceFromFoldable
178 -- , benchSrcIO aheadly "fromFoldable" Ops.sourceFromFoldable
178− , benchSrcIO aheadly "fromFoldableM" Ops.sourceFromFoldableM
179+ ]
179− -- , benchSrcIO aheadly "foldMapWith" Ops.sourceFoldMapWith
180+ , bgroup "aheadly/rate"
180− , benchSrcIO aheadly "foldMapWithM" Ops.sourceFoldMapWithM
181+ [
181− , benchIO "mapM" $ Ops.mapM aheadly
182+ -- XXX arbitrarily large maxRate should be the same as maxRate -1
183+ benchSrcIO aheadly "unfoldrM rate AvgRate 1000000"
184+ (avgRate 1000000 . Ops.sourceUnfoldrM)
183 -- XXX need to use smaller streams to finish in reasonable time
186 -- XXX need to use smaller streams to finish in reasonable time
184 , bgroup "parallely"
187 , bgroup "parallely"