如何在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);