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

您必须订阅 Observable 才能完成工作。

例如，您可以这样做：

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