android - RXJava 将函数应用于 Observable 中的每个元素并返回它的可观察值

Question

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

我的改造服务:

@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 调用观察者线程