Allow that the renamed blocker thread is terminated

typelevel · Jun 30, 2023 · 1e91a9b · 1e91a9b
1 parent 86b65a9
commit 1e91a9b
Showing 1 changed file with 7 additions and 9 deletions.
diff --git a/tests/jvm/src/test/scala/cats/effect/unsafe/WorkerThreadNameSpec.scala b/tests/jvm/src/test/scala/cats/effect/unsafe/WorkerThreadNameSpec.scala
@@ -77,16 +77,14 @@ class WorkerThreadNameSpec extends BaseSpec with TestInstances {
         newComputeThreadName must startWith("io-compute")
         // And index
         newComputeThreadName must endWith("-0")
-        // Check that the same thread is renamed again when it is readded to the compute pool
-        val resetBlockerThread = resetComputeThreads.collectFirst {
-          case (name, `blockerThreadId`) => name
+        // Check that the same thread is renamed again if it is readded to the compute pool
+        resetComputeThreads.map {
+          case (name, `blockerThreadId`) => {
+            name must startWith("io-compute").setMessage("blocker thread name was not reset")
+            name must endWith("-0").setMessage("blocker thread index was not correct")
+          }
+          case _ => ok
         }
-        resetBlockerThread must beSome[String].setMessage(
-          "blocker thread not found after reset")
-        resetBlockerThread must beSome((_: String).startsWith("io-compute"))
-          .setMessage("blocker thread name was not reset")
-        resetBlockerThread must beSome((_: String).endsWith("-0"))
-          .setMessage("blocker thread index was not correct")
       }
     }
   }