RxJava 2 - Observable.zip（）永遠不會發射

Question

我是新來的Reactive。 我想收集來自不同來源的數據並處理結果。 要做到這一點，我正在使用Observable.zip（）方法。但它永遠不會發射，因此回調從未被調用。 我做錯了什麼？

這裏是我嘗試執行代碼的例子：

public void loadData() { 

    Observable.zip(
      Observable.just(42), 
      Observable.just(43), 
      Observable.just(44), 
      (integer, integer2, integer3) -> 
        Log.d(TAG, "zip method called") // This is never called 
    ); 
} 

Answer 1

你要訂閱可觀察讓它做的工作。

例如，你可以這樣做：

public void loadData() { 
    Observable.zip(
      Observable.just(42), 
      Observable.just(43), 
      Observable.just(44), 
      (integer, integer2, integer3) -> 
        Log.d(TAG, "zip method called") 
    ) 
    .subscribe(); //you can also send 3 parameters optional parameters, onNext action, onError action and onComplete action. 
}