Skip to content

Commit

Permalink
Add debug output to flx progress listener test
Browse files Browse the repository at this point in the history
  • Loading branch information
rorbech committed Jul 17, 2024
1 parent b1534c2 commit 853e82c
Showing 1 changed file with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -40,6 +40,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
Expand Down Expand Up @@ -150,6 +151,7 @@ class FLXProgressListenerTests {
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 {
Expand Down

0 comments on commit 853e82c

Please sign in to comment.