RxJava：是否有某種形式的鏈讓我「在繼續之前等待觀察結果A，B，C完成」？

Question

在jQuery中，承諾的想法是做經：

var taskA = $.Deferred(); 
var taskB = $.Deferred(); 
var taskC = $.Deferred(); 

// Callback starts when all tasks are complete/resolved 
$.when(taskA, taskB, taskC).done(function(results) { 
    var resultA = results[0]; 
    var resultB = results[1]; 
    var resultC = results[2]; 
    // ... 
}); 

// Fire off long tasks 
longTask1(function(result) { taskA.resolve("result"); }); 
longTask2(function(result) { taskB.resolve("result"); }); 
longTask3(function(result) { taskC.resolve("result"); }); 

我覺得應該有一個RxJava但equivelant我不知道它的名字。

編輯：添加我的Android活動代碼澄清

/** 
* What I expected to happen: 
* - User has to click buttons A, B and C in order to pass. 
* 
* What actually happens 
* - User clicks any button and passes. 
*/ 
public class RxTestActivity extends AppCompatActivity { 
    PublishSubject<Boolean> subjectClickedA; 
    PublishSubject<Boolean> subjectClickedB; 
    PublishSubject<Boolean> subjectClickedC; 

    @Bind(R.id.btnA) Button btnA; 
    @Bind(R.id.btnB) Button btnB; 
    @Bind(R.id.btnC) Button btnC; 
    @Bind(R.id.labelTest) TextView txtSuccess; 


    @Override 
    protected void onCreate(Bundle savedInstanceState) { 
     super.onCreate(savedInstanceState); 

     setContentView(R.layout.activity_test); 
     ButterKnife.bind(this); 

     subjectClickedA = PublishSubject.create(); 
     subjectClickedB = PublishSubject.create(); 
     subjectClickedC = PublishSubject.create(); 

     // Create an observer which waits until all 3 tasks are complete before 
     // triggering it's own "onCompleted". 
     Observable.merge(subjectClickedA, subjectClickedB, subjectClickedC) 
      // Ensure all subjects are completed 
      // TODO: doesn't work 
      .all(new Func1<Boolean, Boolean>() { 
       @Override 
       public Boolean call(Boolean aBoolean) { 
        // Won't let anything through until all of tasks are complete 
        return subjectClickedA.hasCompleted() && subjectClickedB.hasCompleted() && subjectClickedC.hasCompleted(); 
       } 
      }) 
      .subscribe(new Subscriber<Boolean>() { 
       @Override 
       public void onError(Throwable e) { 
       } 

       @Override 
       public void onNext(Boolean aBoolean) { 
        // aBoolean value comes in as false 
        Log.e("Subscriber onNext", String.valueOf(aBoolean)); 
       } 

       @Override 
       public void onCompleted() { 
        // This triggers on the first button click (no matter which one) 
        // TODO: reward user 
        Log.e("Subscriber", "all tasks completed!"); 
        txtSuccess.setText("Great success!"); 
       } 
      }); 
    } 

    @OnClick(R.id.btnA) 
    protected void onButtonAClicked() { 
     subjectClickedA.onNext(true); 
//  subjectClickedA.onCompleted(); 

     btnA.setEnabled(false); 
    } 

    @OnClick(R.id.btnB) 
    protected void onButtonBClicked() { 
     subjectClickedB.onNext(true); 
//  subjectClickedB.onCompleted(); 

     btnB.setEnabled(false); 
    } 

    @OnClick(R.id.btnC) 
    protected void onButtonCClicked() { 
     subjectClickedC.onNext(true); 
//  subjectClickedC.onCompleted(); 

     btnC.setEnabled(false); 
    } 
} 

Answer 1

您可以通過多種方式相結合的多觀測。

請看看這個。 Combining Observables

本節介紹可用於組合多個Observables的操作符。

• startWith（） - 開始 之前發射的項目的指定的序列發射從可觀察
• 合併的項目（） - 合併多個觀測量到一個
• mergeDelayError（） - 合併多個觀測量到一個，允許 無差錯觀測量到的錯誤傳播之前繼續
• 拉鍊（） - 由兩個或多個觀測量 一起通過指定的功能結合項集的發射併發射根據結果項這個函數的10個函數（rxjava-joins）和（），then（）和when（） - 通過 將兩個或多個可觀察物體發射的物體組合起來組合成一個樣本和計劃中介
• combineLatest（）項是由以下兩種 觀測量的發射，經由 指定功能結合由每個可觀察發出的最新的項目，並且基於此 功能
• 加入（）和羣組加入（）的結果，發出項目 - 結合由發射的項兩個 每當一個Observable中的一個物品落入由另一個物品發出的物品指定的 窗口時，可觀察物體 Obs ervable
• switchOnNext（） - 轉換一個可觀察發射觀測量到 單一可觀察發射這些觀測量