rx-java2 - rxjava2 - 如何压缩也许可以是空的？

Question

我正在尝试进行 3 个 Web 服务调用(例如: getPhoneNumber 、 getFirstName 、 getLastName )并将答案收集到一个公共(public)对象中 Person .任何 Web 服务调用都可以返回 Maybe.empty() .

当试图 zip一起回复，rxjava2跳过 zip 操作并正常终止(没有汇总我的答案)。

有关简化示例，请参见下文:

@Test
public void maybeZipEmptyTest() throws Exception {
    Maybe<Integer> a = Maybe.just(1);
    Maybe<Integer> b = Maybe.just(2);
    Maybe<Integer> empty = Maybe.empty();

    TestObserver<String> observer = Maybe.zip(a,  b, empty, (x, y, e) -> {
        String output = "test: a "+x+" b "+y+" empty "+e;
        return output;
    })
    .doOnSuccess(output -> {
        System.out.println(output);
    })
    .test();

    observer.assertNoErrors();
}

我们如何在 zip 操作中收集空值，而不是跳过/忽略 zip 操作？如果这是解决此问题的错误模式，您建议如何解决此问题？

Answer 1

对于大多数用例，利用 defaultIfEmpty方法是正确的方法。

为了表示最终是可选的(甚至不使用默认值)，我使用了 Java 8 Optional类型来表示。

例如

@Test
public void maybeZipEmptyTest() throws Exception {
    Maybe<Optional<Integer>> a = Maybe.just(Optional.of(1));
    Maybe<Optional<Integer>> b = Maybe.just(Optional.of(2));
    Maybe<Optional<Integer>> empty = Maybe.just(Optional.empty());

    TestObserver<String> observer = Maybe.zip(a,  b, empty, (x, y, e) -> {
        String output = "test: a "+toStringOrEmpty(x)+" b "+toStringOrEmpty(y)+" empty "+toStringOrEmpty(e);
        return output;
    })
    .doOnSuccess(output -> {
        System.out.println(output);
    })
    .test();

    observer.assertNoErrors();
}

private String toStringOrEmpty(Optional<Integer> value){
    if(value.isPresent()){
        return value.get().toString();
    }
    else { 
        return "";
    }
}