2015-05-12 162 views
2

我正在構建一個Android應用程序,並且新增了一個Rxjava,它有一個初學者的問題: 我有一個Observable,如果條件滿足時應該立即發出一些東西。否則,它必須暫停,然後觸發另一個Observable,並等待第二個Observable發出第二個事物。一旦第二東西被髮射時,它(第一Obserable)應繼續,併發射它的對象。Rxjava,如何設計必須等待另一個Observable的Observable

如若1日2次可觀察放在裏面「呼叫」功能可觀察?

如果這個問題聽起來含糊,原諒我,因爲我什至不知道如何設計的代碼。

回答

1

這些是什麼觀測嘗試「觸發」和「暫停」?如果我沒有理解你的問題,你可以做這樣的事情(而不是從頭創建一個可觀察):

Observable<Integer> first = Observable.just(1, 2, 3); 
Observable<Integer> second = Observable.just(4); 

Observable<T> toRun; 

if (condition) { 
    toRun = first; 
} else { 
    toRun = second.concatWith(first); 
} 

toRun.toBlocking().forEach(System.out::println); 
相關問題