В вашем app.gradle добавить зависимости
implementation "com.github.akarnokd:rxjava2-extensions:0.20.8"
затем
Observable<Double> floatObservable = Observable.just(1.2,1.3);
MathObservable
.sumDouble(floatObservable)
.subscribe(new Observer<Double>() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onNext(Double aDouble) {
System.out.println("Sum: " + aDouble);
//if you want int convert here
}
@Override
public void onError(Throwable e) {
}
@Override
public void onComplete() {
}
});
работает нормально .. ответ 2,5