RXJava将函数应用于可观测的每个元素，并返回它的可观测性。

Question

我有一个更新服务，返回一个可观察的，并保存它每次加载。

我的改造服务：

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

职能如下：

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

但是，如果您看到我只是保存和返回相同的对象，还有更简单的方法吗？

Answer 1

你看上去像doOnNext

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

它调用操作，只接受发出的项。

注意，doOnNext调用观察者的线程

Answer 2

也许更好的方法是：

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

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