Rx Java Observableが何らかの条件まで実行します。

Question

いくつかの条件が満たされるまで、observableを実行する方法を見つけようとしています。

は、次の例を考えてみましょう：

myDelayedObservable = createListenerObserver(); 
    public Observable<Boolean> createListenerObserver() { 

     // The part I am looking for 
    } 

    ViewTreeObserver.OnGlobalLayoutListener listenerLayout = new ViewTreeObserver.OnGlobalLayoutListener() { 
     @Override 
     public void onGlobalLayout() { 
      myDelayedObservable.onCompleted(); 
     getTargetView().getViewTreeObserver().removeGlobalOnLayoutListener(this); 

     } 
    }; 

    public void performMultipleRequests() { 

     Observable<Boolean> longRunningTask = Observable.zip(oneRequest, anotherRequest, myDelayedObservable,...); 

    } 

だからアイデアはとてもlongRunningTaskは、私の場合は場合にのみ、すべての要求に加えて、リスナーを（完了、zipを使用して一緒にmyDelayedObservableで、例えば、ダウンロード要求を複数の要求を実行することです完成したレイアウトを表示する）が完了する。

しかし問題は、リスナー用にObservableを作成する正しい方法を見つけることができないことです。これは、擬似コードので

while(!viewIsLaidOut) { 
    // just wait 
} 
observable.complete(); 
// After that `longRunningTask` should be completed 

は、これを達成するための正しい方法を提案してください、私は約Future、Callable考えているが、これは私にとって最善の解決策ではないようだ、バリアのようなものです。

Answer 1

で試してみてください：

PublishSubject<Boolean> myDelayedObservable = PublishSubject.create<>(); 

またはRxJava2

PublishProcessor<Boolean> myDelayedObservable = PublishProcessor.create<>(); 

そして準備のためだけ

myDelayedObservable.onNext(true) 
//not this, myDelayedObservable.onComplete(); 

Answer 2

1を呼び出す）あなたは例えば、同じタイプにmapに、すべての観測を必要とします。 Observable<Boolean>、あなたがそれらをマージすることができるように：

observable1.map(String s -> "...".equals(s)) 
observable2.map(Integer i -> i > 0 && i < 100) 
observable3.map(MyClass m -> true) 
... 

2）単一のストリームにそれらのすべてをマージするObservable.merge()を使用してください。 この目的のためにzipを使用すると、すべてのオブザーバブルが同数のアイテムを出す場合にのみ機能します。そうでない場合は、最初のものが完了するとすぐに残りを待たずに完了します。

Observable<Boolean> allInOne = Observable.merge(observable1, observable2, ...); 

3）myDelayedObservableはただ一つ、いくつかのリスナーがコールバックされるまで不完全allInOneを保有していなければならないそれらの観測量です。この目的のためにSubjectを使用してください：あなたのリスナーの準備ができたら、myDelayedObservable.onComplete()を呼び出す

Subject<Boolean> myDelayedObservable = PublishSubject.create(); 

4）。

5）はallInOneを購読し、完了時に反応する：任意 `onNext`なし

allInOne.subscribe(b -> { ... }, e -> { ... }, 
    () -> { ... go ahead with your next task ... });