Test updates

realm · Jul 18, 2024 · 7901a14 · 7901a14
1 parent df59dcc
commit 7901a14
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/...ync/src/commonTest/kotlin/io/realm/kotlin/test/mongodb/common/FLXProgressListenerTests.kt b/...ync/src/commonTest/kotlin/io/realm/kotlin/test/mongodb/common/FLXProgressListenerTests.kt
@@ -147,6 +147,7 @@ class FLXProgressListenerTests {
     @Test
     fun uploadProgressListener_changesOnly() = runBlocking {
         Realm.open(createSyncConfig(app.createUserAndLogin())).use { realm ->
+            realm.syncSession.uploadAllLocalChanges(TIMEOUT)
             for (i in 0..3) {
                 realm.writeSampleData(TEST_SIZE, timeout = TIMEOUT)
                 realm.syncSession.progressAsFlow(Direction.UPLOAD, ProgressMode.CURRENT_CHANGES)
@@ -291,7 +292,6 @@ class FLXProgressListenerTests {
             .initialSubscriptions {
                 add(it.query<SyncObjectWithAllTypes>("stringField = $0", getTestPartitionValue()))
             }
-            .waitForInitialRemoteData(TIMEOUT)
             .build()
     }
 

diff --git a/.../test-sync/src/jvmTest/kotlin/io/realm/kotlin/test/mongodb/jvm/PlatformNetworkingTests.kt b/.../test-sync/src/jvmTest/kotlin/io/realm/kotlin/test/mongodb/jvm/PlatformNetworkingTests.kt
@@ -20,6 +20,7 @@ import io.realm.kotlin.test.util.use
 import kotlinx.coroutines.flow.first
 import kotlinx.coroutines.withTimeout
 import kotlin.test.Test
+import kotlin.test.assertEquals
 import kotlin.test.assertTrue
 import kotlin.time.Duration.Companion.seconds
 
@@ -51,7 +52,11 @@ class PlatformNetworkingTests {
                         }
                         uploadRealm.syncSession.uploadAllLocalChanges(TIMEOUT)
                         withTimeout(TIMEOUT) {
-                            realm.query<SyncObjectWithAllTypes>().asFlow().first { it.list.size == 1 }
+                            realm.query<SyncObjectWithAllTypes>().asFlow().first {
+                                it.list.size == 1
+                            }.list.first().also {
+                                assertEquals(selector, it.stringField)
+                            }
                         }
                     }
                 }