2017-06-29 18 views
0

私はReactiveで新しいです。 異なるソースからデータを収集し、その結果を処理したいと考えています。 これを行うには、Observable.zip()メソッドを使用しています。しかし、コールバックが呼び出されないようにすることはありません。 どうしたのですか?RxJava 2 - Observable.zip()never emits

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 
    ); 
} 

答えて

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. 
} 
+0

ああ、ええ、もちろん!私は馬鹿だ。あなたは私の日を救ってくれてありがとう:) – Eselfar

+0

喜んで助けになる:) –