RxJava の combineLatest、overload がたくさんあって一発で書けた試しがないので、うまく書けた例を置いておきます。
name と age のいずれかの Observable<T> が変化したときに、 "name - 歳:age" な文字列を push するというものです。
val name = PublishSubject.create<String>()
val age = PublishSubject.create<Int>()
// 型引数指定と BiFunction は省略できないみたい
Observable.combineLatest<String, Int, String>(
name, age, BiFunction { n, a -> "$n - 歳:${a}" })
.subscribe({
Log.d("combineLatest", "onNext - ${it}")
})
// RxKotlin を導入すると型推論が効くとコメントで教えてもらいました
Observables.combineLatest(name, age) { n, a -> "$n - 歳:${a}" }
.subscribe({
Log.d("combineLatest", "onNext - ${it}")
})
// Observable<T> を配列で渡せるけど、第2引数の combiner が Any な配列になっちゃう
Observable.combineLatest(arrayOf(name, age), {
val n = it[0] as String
val a = it[1] as Int
"$n - age:${a}" })
.subscribe({
Log.d("combineLatest", "onNext - ${it}")
})
name.onNext("saito")
age.onNext(24)
name.onNext("yoshida")