RxJava SwitchOnNext Operator Example with Kotlin

rxjava-switch-on-next-operator-example.kt

    val firstObservable = Observable.interval(600, TimeUnit.MILLISECONDS)
    val secondObservable = Observable.interval(100, TimeUnit.MILLISECONDS)

    Observable
        .switchOnNext(firstObservable.map { it -> secondObservable })
        .subscribe(object : Observer<Long> {
            override fun onComplete() {
                println("onComplete")
            }

            override fun onSubscribe(d: Disposable) {
                println("onSubscribe")
            }

            override fun onNext(t: Long) {
                println("onNext : $t")
            }

            override fun onError(e: Throwable) {
            }
        })
    Thread.sleep(1800)