diff --git a/arrow-libs/fx/arrow-fx-coroutines/src/commonTest/kotlin/arrow/fx/coroutines/ParZip9Test.kt b/arrow-libs/fx/arrow-fx-coroutines/src/commonTest/kotlin/arrow/fx/coroutines/ParZip9Test.kt index 0b22d828796..c5868b61648 100644 --- a/arrow-libs/fx/arrow-fx-coroutines/src/commonTest/kotlin/arrow/fx/coroutines/ParZip9Test.kt +++ b/arrow-libs/fx/arrow-fx-coroutines/src/commonTest/kotlin/arrow/fx/coroutines/ParZip9Test.kt @@ -8,7 +8,6 @@ import arrow.fx.coroutines.awaitExitCase import arrow.fx.coroutines.leftException import arrow.fx.coroutines.parZip import arrow.fx.coroutines.throwable -import io.kotest.core.spec.style.StringSpec import io.kotest.matchers.should import io.kotest.matchers.shouldBe import io.kotest.matchers.types.shouldBeTypeOf @@ -22,9 +21,13 @@ import kotlinx.coroutines.CompletableDeferred import kotlinx.coroutines.async import kotlinx.coroutines.channels.Channel import kotlinx.coroutines.CoroutineScope +import kotlin.test.Test +import kotlinx.coroutines.test.runTest -class ParZip9Test : StringSpec({ - "parZip 9 runs in parallel" { +class ParZip9Test { + + @Test + fun parZip9RunsInParallel() = runTest { checkAll(Arb.int(), Arb.int(), Arb.int(), Arb.int(), Arb.int(), Arb.int(), Arb.int(), Arb.int(), Arb.int()) { a, b, c, d, e, f, g, h, i -> val r = Atomic("") val modifyGate1 = CompletableDeferred() @@ -87,8 +90,9 @@ class ParZip9Test : StringSpec({ r.get() shouldBe "$i$h$g$f$e$d$c$b$a" } } - - "Cancelling parZip 9 cancels all participants" { + + @Test + fun CancellingParZip9CancelsAllParticipants() = runTest { val s = Channel() val pa = CompletableDeferred() val pb = CompletableDeferred() @@ -129,8 +133,9 @@ class ParZip9Test : StringSpec({ ph.await().shouldBeTypeOf() pi.await().shouldBeTypeOf() } - - "parZip 9 cancels losers if a failure occurs in one of the tasks" { + + @Test + fun parZip9CancelsLosersIfAFailureOccursInOneOfTheTasks() = runTest { checkAll( Arb.throwable(), Arb.element(listOf(1, 2, 3, 4, 5, 6, 7, 8, 9)) @@ -180,8 +185,9 @@ class ParZip9Test : StringSpec({ r should leftException(e) } } - - "parZip CancellationException on right can cancel rest" { + + @Test + fun parZipCancellationExceptionOnRightCanCancelRest() = runTest { checkAll(Arb.string(), Arb.int(1..9)) { msg, cancel -> val s = Channel() val pa = CompletableDeferred() @@ -229,4 +235,3 @@ class ParZip9Test : StringSpec({ } } } -)