RxJava SwitchOnNext Operator with Kotlin

rxjava-switchOnNext-operator-example.kt

    Observable
        .switchOnNext(
            Observable.interval(100, TimeUnit.MILLISECONDS).map { i ->
                Observable.interval(30, TimeUnit.MILLISECONDS).map { i2 -> i }
            })
        .take(6)
        .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) {
            }
        })