是否有一个 Rx 框架函数可以创建一个可观察对象，该可观察对象在一段时间过去后结束？

Question

有些可观察量就是如此需要。他们希望你倾听、倾听、倾听他们所说的一切，也许是永远！如果我真的只能处理几秒钟的事件怎么办？我可以写一些像

mouseMoves.TakeFor(TimeSpan.FromSeconds(2))

概念上的东西吗，这将创建一个主题，它将传递事件直到经过一定时间，然后取消订阅底层可观察并将其自己的序列标记为完成。我怀疑你可以用手这样写，但似乎必须有一些现有的运算符可以做到这一点。我曾希望 Observable.TimeOut 能够执行我想要的操作，例如使用

mouseMoves.Timeout(TimeSpan.FromSeconds(2), Observable.Empty<T>())

但我认为它所做的是如果观察之间的时间跨度长于可观察对象的超时时间给定值。这也很有用，但不完全是我所追求的。

Answer 1

听起来您需要 TakeUntil：

var source = Observable.FromEventPattern(...);

source.TakeUntil(Observable.Timer(TimeSpan.FromSeconds(2))
   .Subscribe(_ => {});