Fix race condition in Flow test

realm · Dec 20, 2023 · 84a8b7f · 84a8b7f
1 parent a651b4a
commit 84a8b7f
Showing 1 changed file with 5 additions and 5 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
@@ -108,16 +108,16 @@ class RealmNotificationsTests : FlowableTests {
         realm.write { /* Do nothing */ }
         val nextVersion = realm.version()
 
+        c1.receiveOrFail(message = "Failed to receive update event on Channel 1").let { realmChange ->
+            assertIs<UpdatedRealm<Realm>>(realmChange)
+            assertEquals(nextVersion, realmChange.realm.version())
+        }
+
         val observer2 = async {
             realm.asFlow().collect {
                 c2.send(it)
             }
         }
-
-        c1.receiveOrFail(message = "Failed to receive update event on Channel 1").let { realmChange ->
-            assertIs<UpdatedRealm<Realm>>(realmChange)
-            assertEquals(nextVersion, realmChange.realm.version())
-        }
         c2.receiveOrFail(message = "Failed to receive initial event on Channel 2").let { realmChange ->
             assertIs<InitialRealm<Realm>>(realmChange)
             assertEquals(nextVersion, realmChange.realm.version())