如何在 ReactiveX 中保存数据答案

【问题标题】：How can I save data in ReactiveX如何在 ReactiveX 中保存数据
【发布时间】：2018-07-10 09:18:48
【问题描述】：

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

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

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

【问题讨论】：

“保存数据”是什么意思？ Rx 有一些操作符，用于收集以前的发射（收集、扫描）。您确定响应式流适合您的任务吗？

标签： rx-java reactive-programming reactivex rx-py

【解决方案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);

【讨论】：