Attempt to fix race conditions in RealmNotificationsTests

realm · Nov 27, 2023 · 4d78d2b · 4d78d2b
1 parent 7d2e88b
commit 4d78d2b
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...rc/commonTest/kotlin/io/realm/kotlin/test/common/notifications/RealmNotificationsTests.kt b/...rc/commonTest/kotlin/io/realm/kotlin/test/common/notifications/RealmNotificationsTests.kt
@@ -73,7 +73,7 @@ class RealmNotificationsTests : FlowableTests {
     @Test
     override fun initialElement() {
         runBlocking {
-            val c = Channel<RealmChange<Realm>>(1)
+            val c = Channel<RealmChange<Realm>>(0)
             val startingVersion = realm.version()
             val observer = async {
                 realm.asFlow().collect {
@@ -93,7 +93,7 @@ class RealmNotificationsTests : FlowableTests {
     @Test
     override fun asFlow() {
         runBlocking {
-            val c = Channel<RealmChange<Realm>>(1)
+            val c = Channel<RealmChange<Realm>>(0)
             val startingVersion = realm.version()
             val observer = async {
                 realm.asFlow().collect {
@@ -122,8 +122,8 @@ class RealmNotificationsTests : FlowableTests {
 
     @Test
     override fun cancelAsFlow() = runBlocking<Unit> {
-        val c1 = Channel<RealmChange<Realm>>(1)
-        val c2 = Channel<RealmChange<Realm>>(1)
+        val c1 = Channel<RealmChange<Realm>>(0)
+        val c2 = Channel<RealmChange<Realm>>(0)
         val startingVersion = realm.version()
 
         val observer1 = async {