2015-05-12 163 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); 
相关问题