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

RxJava 2 - Observable.zip() 从不发出

RxJava 2 - Observable.zip() never emits

android

observable

rx-java2