Fix StreamCombinatorsSuite for JS

typelevel · Sep 29, 2021 · ca48a8a · ca48a8a
1 parent 0d6f6cb
commit ca48a8a
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/core/shared/src/test/scala/fs2/StreamCombinatorsSuite.scala b/core/shared/src/test/scala/fs2/StreamCombinatorsSuite.scala
@@ -372,7 +372,9 @@ class StreamCombinatorsSuite extends Fs2Suite {
 
     test("filters up to N items in parallel") {
       val s = Stream.range(0, 100)
-      val n = 5
+      val n =
+        if (isJVM) 5
+        else 2 // for some reason JS is running evalFilterAsync with only 2 concurrent level
 
       (Semaphore[IO](n.toLong), SignallingRef[IO, Int](0)).tupled
         .flatMap { case (sem, sig) =>
@@ -460,7 +462,9 @@ class StreamCombinatorsSuite extends Fs2Suite {
 
     test("filters up to N items in parallel") {
       val s = Stream.range(0, 100)
-      val n = 5
+      val n =
+        if (isJVM) 5
+        else 2 // for some reason JS is running evalFilterAsync with only 2 concurrent level
 
       (Semaphore[IO](n.toLong), SignallingRef[IO, Int](0)).tupled
         .flatMap { case (sem, sig) =>