Skip to content

Commit 96be806

Browse files
committed
Fix logs for BackPressure test
1 parent 5736984 commit 96be806

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

krpc/krpc-test/src/commonTest/kotlin/kotlinx/rpc/krpc/test/BackPressureTest.kt

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -138,10 +138,10 @@ abstract class BackPressureTestBase {
138138
repeat(1000) {
139139
impl.clientStreamCounter.incrementAndGet()
140140
emit(it)
141-
}
142-
counter++
143-
if (counter % 10 == 0) {
144-
println("Iteration: $counter")
141+
counter++
142+
if (counter % 10 == 0) {
143+
println("Iteration: $counter")
144+
}
145145
}
146146
})
147147
}

0 commit comments

Comments
 (0)