Use runBlocking on Native

arrow-kt · Oct 24, 2023 · 886704c · 886704c
1 parent 45b387b
commit 886704c
Show file tree

Hide file tree

Showing 4 changed files with 19 additions and 4 deletions.
diff --git a/arrow-libs/core/arrow-atomic/src/commonTest/kotlin/arrow/atomic/AtomicIntTest.kt b/arrow-libs/core/arrow-atomic/src/commonTest/kotlin/arrow/atomic/AtomicIntTest.kt
@@ -1,6 +1,7 @@
 package arrow.atomic
 
 import arrow.fx.coroutines.parMap
+import io.kotest.common.runBlocking
 import kotlin.test.Test
 import kotlinx.coroutines.test.runTest
 import io.kotest.matchers.shouldBe
@@ -97,7 +98,7 @@ class AtomicIntTest {
   }
 
   @Test
-  fun concurrentModifications() = runTest {
+  fun concurrentModifications() = runBlockingOnNative {
     val finalValue = 50_000
     val r = AtomicInt(0)
     (0 until finalValue).parMap { r.update { it + 1 } }

diff --git a/arrow-libs/core/arrow-atomic/src/commonTest/kotlin/arrow/atomic/AtomicLongTest.kt b/arrow-libs/core/arrow-atomic/src/commonTest/kotlin/arrow/atomic/AtomicLongTest.kt
@@ -1,6 +1,7 @@
 package arrow.atomic
 
 import arrow.fx.coroutines.parMap
+import io.kotest.common.runBlocking
 import kotlin.test.Test
 import kotlinx.coroutines.test.runTest
 import io.kotest.matchers.shouldBe
@@ -97,7 +98,7 @@ class AtomicLongTest {
   }
 
   @Test
-  fun concurrentModifications() = runTest {
+  fun concurrentModifications() = runBlockingOnNative {
     val finalValue = 50_000
     val r = AtomicLong(0)
     (0 until finalValue).parMap { r.update { it + 1 } }

diff --git a/arrow-libs/core/arrow-atomic/src/commonTest/kotlin/arrow/atomic/AtomicTest.kt b/arrow-libs/core/arrow-atomic/src/commonTest/kotlin/arrow/atomic/AtomicTest.kt
@@ -102,11 +102,10 @@ class AtomicTest {
   }
 
   @Test
-  fun concurrentModifications() = runBlocking {
+  fun concurrentModifications() = runBlockingOnNative {
     val finalValue = 50_000
     val r = Atomic("")
     (0 until finalValue).parMap { r.update { it + "a" } }
     r.value shouldBe "a".repeat(finalValue)
-    Unit
   }
 }
diff --git a/arrow-libs/core/arrow-atomic/src/commonTest/kotlin/arrow/atomic/Util.kt b/arrow-libs/core/arrow-atomic/src/commonTest/kotlin/arrow/atomic/Util.kt
@@ -0,0 +1,14 @@
+package arrow.atomic
+
+import io.kotest.common.runBlocking
+import kotlinx.coroutines.test.runTest
+import io.kotest.common.Platform
+import io.kotest.common.platform
+
+fun runBlockingOnNative(testBody: suspend () -> Unit) {
+  if (platform == Platform.Native)
+    runBlocking(testBody)
+  else
+    runTest { testBody() }
+}
+