这是一项学术练习,我是 Reactive Extensions 的新手,并试图了解这项技术。我为自己设定了一个目标,即制作一个返回 Pi 的连续数字的 IObservable(由于不相关的原因,我现在恰好对 Pi 很感兴趣)。Reactive Extensions 包含用于制作 observables 的运算符,它们给出的指导是您应该“几乎永远不需要创建自己的 IObsevable”。但是我看不到如何使用现成的运算符和方法来做到这一点。让我再解释一下。
我计划使用一种算法,该算法将涉及扩展 Arctan 的泰勒级数。为了获得下一位 Pi,我将在该系列中扩展更多术语。
所以我需要异步进行系列扩展,偶尔将下一个计算数字扔给 IObserver。我显然不想为每个新数字从头开始重新计算。
有没有办法使用 RX 的内置运算符来实现这种行为,还是我必须从头开始编写一个 IObservable?什么策略表明自己?