정상에서 IT를 외치다

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

안드로이드

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

Black-Jin 2019. 4. 4. 16:46
반응형

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")


<참고자료>

기본 예제

실무 예제

반응형
Comments