c# - 从较短的可观察对象创建长期运行的可观察对象？

Question

我有一个返回 1 或 2 个项目然后完成的简短可观察对象的方法。

我想要一个持续运行的可观察对象，当我调用一个方法时，会创建短可观察对象并将其合并到运行时间较长的可观察对象中。

有没有办法用可观察的操作符来做到这一点？还是我应该只使用主题？

Answer 1

当您提出问题时，没有办法绕过主题的使用，特别是因为您需要一个方法调用来触发现有流上的事件。

但是你可以将subjects的使用限制在最低限度，也就是这个方法调用:

Subject<Unit> trigger;

void RefreshMethod() { trigger.OnNext(Unit.Default); }

IObservable<Item> GetLongObservable() {
    return trigger.SelectMany(_ => GetShortObservable());
}

理想情况下，根据调用 RefreshMethod 的位置，您可以尝试进一步传播 Rx 的使用，并用其背后的实际事件替换主题。 p>