rx-java - 如何在 ReactiveX 中保存数据

Question

我是 ReactiveX 的新手，我有一个问题。如何在 ReactiveX 中保存数据。例如。我有这个代码。

last_price = market_data_service.get_last_price("IBM")
difference = previous_last_price - last_price 

为了正确工作，我需要知道价格的先前值。如何在 ReactiveX 中保存以前的价格。

Answer 1

在 RX 方法中返回Observable<T>. 所以在你的情况下，上面应该是：

int previous_last_price = 10;
Single<Integer> market_data_service = Single.just(5);
Single<Integer> difference = market_data_service.map(last_price -> previous_last_price - last_price);