2017-06-29 74 views
0

我是新来的Reactive。 我想收集来自不同来源的数据并处理结果。 要做到这一点,我正在使用Observable.zip()方法。但它永远不会发射,因此回调从未被调用。 我做错了什么?RxJava 2 - 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 
    ); 
} 

回答

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

很高兴成为帮助:) –