使用带有可能不会发出值的Maybe的zip()

Question

我试图Maybe一次执行两个并且一旦完成就调用一个特定的方法.如果两个Observable都返回一个值,但是在某些情况下,一个人可能不会发出一个只调用doOnComplete而不是调用的项,这是有效的doOnSuccess.因此,如果其中一个Maybes'没有调用doOnSuccess该zip()块就不会被执行.我想知道如何处理这种情况？

遵循我的代码(剥离到基本部分):

private void fetchData(){
    Maybe<Integer> maybeOne = getId(); // may return Maybe.empty()
    Maybe<List<String>> maybeTwo = getList();
    Maybe.zip(maybeOne, maybeTwo, (id, list) -> {
        initView(id, list); // only called if values have been emitted
        return true;
    }).subscribe();
}

我希望zip()块总是被调用,但是如果Maybe没有调用则使用null值onSuccess.情况并非如此,我可以处理这样的情况吗？

Answer 1

您可以使用materialize运算符.它基本上将串行调用转换为对象(包装在Notification对象内).

Observable.zip(maybeOne.toObservable().materialize(),
                maybeTwo.toObservable().materialize(), (id, list) -> {
                    Log.d(TAG, "zip completed");
                    return true;
                }).subscribe();

现在您zip将永远"完成",但您可以使用以下方法检索您的真实数据:

id.getValue()

如果你可能Maybe.empty()那么它将不会返回值,而是null.