RxJava Zip Operator Example with Kotlin

rxjava-zip-operator-example.kt

    val alphabets1 = Observable.intervalRange(0, 1, 1, 1, TimeUnit.SECONDS).map { id -> "A" + id }
    val alphabets2 = Observable.intervalRange(0, 2, 2, 1, TimeUnit.SECONDS).map { id -> "B" + id }

    Observable.zip(alphabets1, alphabets2,
        BiFunction<String, String, String> { t1, t2 -> "$t1 $t2" })
        .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) {

            }
        })