Decrease concurrency/replicas in CallbackStackSpec

Co-authored-by: Sam Pillsworth <[email protected]>
armanbilge · Jan 15, 2024 · 3e9f22e · 3e9f22e
1 parent eba766e
commit 3e9f22e
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/tests/shared/src/test/scala/cats/effect/CallbackStackSpec.scala b/tests/shared/src/test/scala/cats/effect/CallbackStackSpec.scala
@@ -41,10 +41,12 @@ class CallbackStackSpec extends BaseSpec with DetectPlatform {
           packed <- IO(stack.pack(1))
         } yield (if (removed) 1 else 0) + packed
 
+        val concurrency = Math.max(2, Runtime.getRuntime().availableProcessors())
+
         pushClearPack
-          .parReplicateA(3000)
+          .parReplicateA(concurrency)
           .product(IO(stack.pack(1)))
-          .flatMap { case (xs, y) => IO((xs.sum + y) mustEqual 3000) }
+          .flatMap { case (xs, y) => IO((xs.sum + y) mustEqual concurrency) }
           .replicateA_(if (isJS || isNative) 1 else 1000)
           .as(ok)
       }