Merge pull request #3952 from armanbilge/topic/callback-stack-spec-le…

…ss-replicas Decrease concurrency/replicas in `CallbackStackSpec`
typelevel · Jan 15, 2024 · 4751662 · 4751662
2 parents f1395d7 + 3e9f22e
commit 4751662
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)
       }