接收.Net在关闭后在第一个值和下一个值上打开的窗口运算符

GroupByUntil似乎能做到这一点:

public static IObservable<IObservable<T>> LazyWindow<T, TClosing>(
    this IObservable<T> source, Func<IObservable<TClosing>> windowClose) => source
        .GroupByUntil(x => 0, group => windowClose())
        .Select(x => (IObservable<T>) x);

编辑:不要使用 null 作为常量组密钥,它在框架内产生了NRE。很奇怪。