diff --git a/bench/Scheduler.hs b/bench/Scheduler.hs
--- a/bench/Scheduler.hs
+++ b/bench/Scheduler.hs
@@ -71,7 +71,7 @@
     , bench "unliftio/pooledReplicateConcurrently" $
       nfIO $ pooledReplicateConcurrently n (newIORef x >>= fxIO)
     , bench "streamly/replicateM" $
-      nfIO $ S.runStream $ asyncly $ S.replicateM n (newIORef x >>= fxIO)
+      nfIO $ S.drain $ asyncly $ S.replicateM n (newIORef x >>= fxIO)
     , bench "async/replicateConcurrently" $ nfIO $ A.replicateConcurrently n (newIORef x >>= fxIO)
     , bench "monad-par/replicateM" $ nfIO $ runParIO $ replicateM n (newFull_ x >>= fxPar)
     , bench "base/replicateM" $ nfIO $ replicateM n (newIORef x >>= fxIO)
@@ -93,7 +93,7 @@
     ("map/" <> name <> str)
     [ bench "scheduler/traverseConcurrently" $ nfIO $ traverseConcurrently Par fxIO [1 .. n]
     , bench "unliftio/pooledTraverseConcurrently" $ nfIO $ pooledMapConcurrently fxIO [1 .. n]
-    , bench "streamly/mapM" $ nfIO $ S.runStream $ asyncly $ S.mapM fxIO $ S.enumerateFromTo 1 n
+    , bench "streamly/mapM" $ nfIO $ S.drain $ asyncly $ S.mapM fxIO $ S.enumerateFromTo 1 n
     , bench "async/mapConcurrently" $ nfIO $ A.mapConcurrently fxIO [1 .. n]
     , bench "par/mapM" $ nfIO $ mapM fxParIO [1 .. n]
     , bench "monad-par/mapM" $ nfIO $ runParIO $ mapM fxPar [1 .. n]
diff --git a/scheduler.cabal b/scheduler.cabal
--- a/scheduler.cabal
+++ b/scheduler.cabal
@@ -1,5 +1,5 @@
 name:                scheduler
-version:             1.4.2.1
+version:             1.4.2.2
 synopsis:            Work stealing scheduler.
 description:         A work stealing scheduler that is primarly developed for [massiv](https://github.com/lehins/massiv) array librarry, but it is general enough to be useful for any computation that fits the model of few workers many jobs.
 homepage:            https://github.com/lehins/haskell-scheduler
@@ -80,7 +80,7 @@
                      , scheduler
                      , parallel
                      , unliftio >= 0.2.10
-                     , streamly >= 0.6.1 && < 0.7
+                     , streamly >= 0.6.1
   default-language:    Haskell2010
 
 source-repository head