diff --git a/packages/test-sync/src/commonTest/kotlin/io/realm/kotlin/test/mongodb/common/FLXProgressListenerTests.kt b/packages/test-sync/src/commonTest/kotlin/io/realm/kotlin/test/mongodb/common/FLXProgressListenerTests.kt index 53728762cf..833c462e63 100644 --- a/packages/test-sync/src/commonTest/kotlin/io/realm/kotlin/test/mongodb/common/FLXProgressListenerTests.kt +++ b/packages/test-sync/src/commonTest/kotlin/io/realm/kotlin/test/mongodb/common/FLXProgressListenerTests.kt @@ -20,6 +20,8 @@ import io.realm.kotlin.Realm import io.realm.kotlin.entities.sync.SyncObjectWithAllTypes import io.realm.kotlin.ext.query import io.realm.kotlin.internal.platform.runBlocking +import io.realm.kotlin.log.LogLevel +import io.realm.kotlin.log.RealmLog import io.realm.kotlin.mongodb.User import io.realm.kotlin.mongodb.sync.Direction import io.realm.kotlin.mongodb.sync.Progress @@ -40,6 +42,7 @@ import kotlinx.coroutines.flow.buffer import kotlinx.coroutines.flow.filter import kotlinx.coroutines.flow.first import kotlinx.coroutines.flow.last +import kotlinx.coroutines.flow.onEach import kotlinx.coroutines.flow.scan import kotlinx.coroutines.flow.takeWhile import kotlinx.coroutines.supervisorScope @@ -146,10 +149,12 @@ class FLXProgressListenerTests { @Test fun uploadProgressListener_changesOnly() = runBlocking { + RealmLog.setLevel(LogLevel.ALL) Realm.open(createSyncConfig(app.createUserAndLogin())).use { realm -> for (i in 0..3) { realm.writeSampleData(TEST_SIZE, timeout = TIMEOUT) realm.syncSession.progressAsFlow(Direction.UPLOAD, ProgressMode.CURRENT_CHANGES) + .onEach { println("Progress[$i] $it") } .run { withTimeout(TIMEOUT) { last().let { diff --git a/packages/test-sync/src/jvmTest/kotlin/io/realm/kotlin/test/mongodb/jvm/PlatformNetworkingTests.kt b/packages/test-sync/src/jvmTest/kotlin/io/realm/kotlin/test/mongodb/jvm/PlatformNetworkingTests.kt index ed97a22ea5..d33e150447 100644 --- a/packages/test-sync/src/jvmTest/kotlin/io/realm/kotlin/test/mongodb/jvm/PlatformNetworkingTests.kt +++ b/packages/test-sync/src/jvmTest/kotlin/io/realm/kotlin/test/mongodb/jvm/PlatformNetworkingTests.kt @@ -20,7 +20,6 @@ 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