這個(gè)頁(yè)面展示的操作符可用于組合多個(gè)Observables。
startWith(?)
— 在數(shù)據(jù)序列的開(kāi)頭增加一項(xiàng)數(shù)據(jù)merge(?)
— 將多個(gè)Observable合并為一個(gè)mergeDelayError(?)
— 合并多個(gè)Observables,讓沒(méi)有錯(cuò)誤的Observable都完成后再發(fā)射錯(cuò)誤通知zip(?)
— 使用一個(gè)函數(shù)組合多個(gè)Observable發(fā)射的數(shù)據(jù)集合,然后再發(fā)射這個(gè)結(jié)果and(?)
, then(?)
, and when(?)
— (rxjava-joins
) 通過(guò)模式和計(jì)劃組合多個(gè)Observables發(fā)射的數(shù)據(jù)集合combineLatest(?)
— 當(dāng)兩個(gè)Observables中的任何一個(gè)發(fā)射了一個(gè)數(shù)據(jù)時(shí),通過(guò)一個(gè)指定的函數(shù)組合每個(gè)Observable發(fā)射的最新數(shù)據(jù)(一共兩個(gè)數(shù)據(jù)),然后發(fā)射這個(gè)函數(shù)的結(jié)果join(?)
and groupJoin(?)
— 無(wú)論何時(shí),如果一個(gè)Observable發(fā)射了一個(gè)數(shù)據(jù)項(xiàng),只要在另一個(gè)Observable發(fā)射的數(shù)據(jù)項(xiàng)定義的時(shí)間窗口內(nèi),就將兩個(gè)Observable發(fā)射的數(shù)據(jù)合并發(fā)射switchOnNext(?)
— 將一個(gè)發(fā)射Observables的Observable轉(zhuǎn)換成另一個(gè)Observable,后者發(fā)射這些Observables最近發(fā)射的數(shù)據(jù)(
rxjava-joins
) — 表示這個(gè)操作符當(dāng)前是可選的rxjava-joins
包的一部分,還沒(méi)有包含在標(biāo)準(zhǔn)的RxJava操作符集合里