[Zip, CombineLater, WithLatestFrom] 리액티브 예제 따라하기

Zip, CombineLater, WithLatestFrom 예제 살펴보기

/**
 *  Zip
 */
Observable.zip(
    Observable.just(1, 2, 3),
    Observable.just(10, 20, 30),
    Observable.just(100, 200, 300),
    Observable.just(1000, 2000, 3000),
    object : Function4<Int, Int, Int, Int, Int> {
        override fun apply(t1: Int, t2: Int, t3: Int, t4: Int): Int {
            return t1 + t2 + t3 + t4
        }
    }
).subscribe({
    Dlog.d("$it")
}){
    Dlog.e(it.message)
}.also {
    compositeDisposable.add(it)
}

/**
 *  merge
 */
val inc = RxView.clicks(btnPlus).map { +1 }
val dec = RxView.clicks(btnMinus).map { -1 }

Observable.merge(inc, dec)
    .scan(0) { acc: Int, value: Int -> acc + value }
    .subscribe { textView.text = it.toString() }
    .apply { compositeDisposable.add(this) }



/**
 *  combineLatest
 *
 *  여러 개의 옵저버블을 가질 수 있습니다.
 *  각각의 옵저버블의 데이터를 방행한 후에는 어느 옵저버블에서 값을 발행하던지 최신값으로 갱신해준다.
 */
val item1 = Observable.just(1, 2, 3)
val item2 = Observable.just(4, 5, 6)

val observableList = Arrays.asList(item1, item2)

val observable1 = Observable.combineLatest(observableList) {items ->
    var count = 0
    for(item in items) {
        Dlog.d("item : $item")
        count += item.toString().toInt()
    }
}

observable1.subscribe({
    Dlog.d("$it")
}) {
    Dlog.e(it.message)
}.also {
    compositeDisposable.add(it)
}




/**
 * withLatestFrom
 *
 * 오직 두 개의 옵저버블을 가질 수 있다.
 * 두번 째 옵저버블이 emit 하고 나서 부터 첫 번째 옵저버블이 합쳐진다.
 *
 */
val firstSubject = PublishSubject.create<String>()
val secondSubject = PublishSubject.create<String>()

val withLatestFrom = firstSubject.withLatestFrom(
    secondSubject, object : BiFunction<String, String, String> {
    override fun apply(first: String, second: String): String {
        return  first + second
    }
})

withLatestFrom.subscribe({
    Dlog.d(it)
}){
    Dlog.e("error : ${it.message}")
}.also {
    compositeDisposable.add(it)
}

firstSubject.onNext("a")
secondSubject.onNext("b")
firstSubject.onNext("c")
firstSubject.onNext("d")
secondSubject.onNext("e")
firstSubject.onNext("f")
secondSubject.onNext("g")

<참고자료>

기본 예제

실무 예제