如何在iObservable上执行未来



我在构建工作流程时会不断遇到这个问题,因此这是问题。整个问题是时间。

当我将IObservable连接到某些GUI元素时,这一切都很好。GUI元素仅在获得新数据时就进行了更新,这就是我关心的全部。

但是还有另一个类别(有两个子类别) - 无past数据(当前 未来和未来)。我想使用这样的IObservable(或以这种方式使用Subscribe),我只会获得将来的数据。

当您有一些转向逻辑时,重要的例子至关重要 - 我订阅地震指示器,如果值达到阈值,我将启动警报。现在,如果我的可观察到我会向我发送旧数据,我将启动falder警报。不好: - )。

因此,是否有一种方法可以将IObservable限制为将来可观察的,或以这种限制方式执行Subscribe?到目前为止,我依靠Subject S,因为它们的行为在时间到了。

总结一下 - 我想总共有3种类型:在任何时间(这里已经有IObservable),对于当前 未来数据,仅第三个数据 - 仅将来数据。

更新:有关Ingmativity注释,请参见下文 - 假设我有具有给定语义的生产者,例如当前 Future(例如BehaviorSubject)。现在,我可以通过BehaviorSubject传递或可以通过IObservable-但是在后一种情况下,我必须与所有人一起使用IObservable,因为我没有机会执行它(至少我看不到如何)即使在运行时。

您正在承担在订户上生产/处理过去数据的责任。它应该是生产者的功能。即,如果您不想获得最后(过去)值,那么它不应订阅带有重播/行为语义的序列。

序列应仅产生新值。如果GUI的其他部分想要o获取PADT数据,那么他们将订阅其他序列。现在,此序列可能只是通过相同序列的急切的(连接)重播,也可能是由不同的后端查询提供的值。

反应性交易者示例项目招致一个涉及这两个问题的GUI

最新更新