RXJava將函數應用於Observable中的每個元素並返回它的可觀察值

我有一個改進服務，它返回一個Observable並在每次加載時保存它。RXJava將函數應用於Observable中的每個元素並返回它的可觀察值

我的改裝服務：

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

而且功能：

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

但如果你看到我只是不保存並返回相同的對象，有沒有簡單的方法？

2015-07-01 Caipivara

你找'doOnEach' https://github.com/ReactiveX/RxJava/wiki/Observable-Utility-Operators#dooneach？ – LordRaydenMK

您正在尋找doOnNext

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

它調用的動作，簡單地接受發射項目。
注意，上觀察者的線程doOnNext電話

2015-07-03 09:58:02 zella

也許它能夠更好地使用：

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

地圖被用於將一些改變每個項目。

2015-07-01 16:19:37

但我返回觀察者，我想將其「祕密」應用於訂戶 – Caipivara

你是什麼意思與「祕密」？ –

不確定是否存在其他方式？ –

回答