c# - Reactive Throttle 返回在 TimeSpan 内添加的所有项目

Question

给定一个 IObservable<T>有没有办法使用 Throttle行为(添加项目时重置计时器，但是否返回该时间内添加的所有项目的集合？

Buffer提供类似的功能，它将数据分块到 IList<T>在每个时间跨度或计数上。但是每次添加项目时我都需要时间来重置。

我在这里看到过类似的问题，Does reactive extensions support rolling buffers? ，但答案似乎并不理想，而且有点陈旧，所以我想知道 Rx-Main 的发布版本现在是否支持开箱即用的此功能。

Answer 1

作为我answered in the other post ， 是的你可以!使用 Observable 的 Throttle 和 Window 方法:

public static IObservable<IList<T>> BufferUntilInactive<T>(this IObservable<T> stream, TimeSpan delay)
{
    var closes = stream.Throttle(delay);
    return stream.Window(() => closes).SelectMany(window => window.ToList());
}