File tree Expand file tree Collapse file tree 2 files changed +4
-5
lines changed
kotlinx-coroutines-rx2/src/test/kotlin/guide Expand file tree Collapse file tree 2 files changed +4
-5
lines changed Original file line number Diff line number Diff line change @@ -350,7 +350,7 @@ fun main(args: Array<String>) = runBlocking<Unit> {
350350 .doOnComplete { println (" Complete" ) }
351351 .subscribe { x ->
352352 println (" Received $x " )
353- Thread .sleep(200 ) // 200 ms to process each item
353+ Thread .sleep(300 ) // 300 ms to process each item
354354 }
355355 delay(2000 ) // suspend main thread for couple of seconds
356356}
Original file line number Diff line number Diff line change 1717// This file was automatically generated from coroutines-guide-reactive.md by Knit tool. Do not edit.
1818package guide.reactive.basic.example05
1919
20- import io.reactivex.schedulers.Schedulers
21- import kotlinx.coroutines.experimental.delay
22- import kotlinx.coroutines.experimental.runBlocking
20+ import kotlinx.coroutines.experimental.*
2321import kotlinx.coroutines.experimental.rx2.rxFlowable
22+ import io.reactivex.schedulers.Schedulers
2423
2524fun main (args : Array <String >) = runBlocking<Unit > {
2625 // coroutine -- fast producer of elements in the context of the main thread
@@ -36,7 +35,7 @@ fun main(args: Array<String>) = runBlocking<Unit> {
3635 .doOnComplete { println (" Complete" ) }
3736 .subscribe { x ->
3837 println (" Received $x " )
39- Thread .sleep(200 ) // 200 ms to process each item
38+ Thread .sleep(300 ) // 300 ms to process each item
4039 }
4140 delay(2000 ) // suspend main thread for couple of seconds
4241}
You can’t perform that action at this time.
0 commit comments