如何在 RxJava 中对两个 Single<Optional<>> 值求和

Question

如何总结Java 11中的两个

Single<Optional<MonetaryAmount>>

？

我正在使用 RxJava，但我认为这没有任何意义。

例如：

Single<Optional<MonetaryAmount>> first = someMethod1(a, b);
Single<Optional<MonetaryAmount>> second = someMethod2(a, b);

我想做这样的事情，不是语法上而是逻辑上：

Single<Optional<MonetaryAmount>> result = first + second;

我尝试做这样的事情，但它在 Java 11 中不起作用

Single<Optional<MonetaryAmount>> result = Stream.concat(first, second)
                                                .reduce(MonetaryAmount::sum);

我该怎么做？

Answer 1

使用

concatMapSingle

和

mapOptional

获取当前值：

Observable<Single<Optional<MonetaryAmount>>> amounts = 
    Observable.fromArray(first, second);

amounts.concatMapSingle(v -> v)
.mapOptional(v -> v) // RxJava 3
.reduce(MonetaryAmount::sum)
;

对于 RxJava 2，使用过滤器+映射组合：

.filter(Optional::isPresent)
.map(Optional::get)