RxJava CombineLatest Operator Example with Kotlin

rxjava-combine-latest-operator-example.kt

    val observable1 = Observable.interval(400, TimeUnit.MILLISECONDS)
    val observable2 = Observable.interval(250, TimeUnit.MILLISECONDS)

    Observable.combineLatest(
        observable1,
        observable2,
        object : BiFunction<Long, Long, String> {
            override fun apply(t1: Long, t2: Long): String {
                return "observable1 value: $t1 , observable2 value: $t2"
            }
        })
        .take(5)
        .subscribe(object : Observer<String> {
            override fun onComplete() {
                println("onComplete")
            }

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

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

            override fun onError(e: Throwable) {

            }

        })

    TimeUnit.SECONDS.sleep(1);