RXJava 将函数应用于 Observable 中的每个元素并且 return 它是可观察的

Question

我有一个改造服务，return是一个 Observable 并在每次加载时保存它。

我的改造服务：

@GET("url")
Observable<Order> getOrder();

以及函数：

return SERVICE.getOrder()
            .map(order -> {
                save(order);
                return order;
            });

但是如果你看到我只是保存和return同一个对象，有没有更简单的方法？

Answer 1

也许更好用：

        .subscribe(new Action1<StatsChartData>() {
            @Override
            public void call(Order order) {
                save(order);
            }
        });

地图用于对每个项目应用一些更改。

Answer 2

您正在寻找doOnNext

return SERVICE.getOrder()
            .doOnNext(order -> {
                    save(order);
            })

它是调用操作，仅接受发出的项目。
请注意，doOnNext 调用观察者的线程

RXJava 将函数应用于 Observable 中的每个元素并且 return 它是可观察的

RXJava apply function to each element in Observable and return it´s observable

android

reactive-programming

rx-java

retrofit