Rx.Net中Window搭配Concat为何未按预期输出？

核心误解 #

Window(2, 1)确实会生成你预期的窗口序列（[0,1]、[1,2]、[2,3]...），但问题出在*Concat的订阅时机*和Observable.Interval的热序列特性：

• Interval是热序列，元素一旦发射就会消失，不会等待后续订阅者。
• Concat会按顺序逐个订阅窗口：先订阅第一个窗口，等它完成后才会订阅第二个窗口。当第二个窗口被订阅时，源序列已经发射过1了，所以第二个窗口只能接收到2；第三个窗口被订阅时，2也已经发射过，只能接收到3，以此类推。最终每个窗口只输出一个后续元素，拼接后就是连续的单个数字。

Merge会同时订阅所有窗口，所以每个窗口都能捕获到对应的元素，符合你的预期，但它无法保证严格顺序（虽然这个场景下看起来顺序没问题，但你的实际场景需要保序，所以Merge不适用）。

实现预期行为的两种方案 #

方案1：改用Buffer操作符（最简洁） #

Buffer(2, 1)直接将源序列打包成你需要的数对列表，天生保持顺序，不需要额外处理窗口和拼接：

Observable.Interval(TimeSpan.FromSeconds(1))
          .Buffer(2, 1)
          .Where(buffer => buffer.Count == 2) // 过滤源序列结束时可能出现的不完整缓冲区
          .Select(buffer => $"[{buffer[0]}, {buffer[1]}]") // 这里替换成你需要的窗口操作
          .Subscribe(Console.WriteLine);

输出就是[0,1]、[1,2]、[2,3]...完全符合预期，且顺序严格保持。

方案2：将源序列转为可共享序列（适配Window+Concat场景） #

如果你的实际场景必须使用Window，可以通过Publish().RefCount()让源序列的元素被所有窗口共享，避免后续窗口丢失元素：

var source = Observable.Interval(TimeSpan.FromSeconds(1))
                       .Publish()
                       .RefCount(); // 转为可共享的序列，所有订阅者接收相同的元素

source.Window(2, 1)
      .Select(window => window.ToList()) // 这里执行你需要的窗口操作
      .Concat()
      .Where(list => list.Count == 2)
      .Select(list => $"[{list[0]}, {list[1]}]")
      .Subscribe(Console.WriteLine);

Publish().RefCount()让所有窗口订阅的是同一个源序列实例，元素会被广播给所有活跃的窗口，这样每个窗口都能捕获到对应的两个元素，Concat按顺序拼接后就能得到预期的数对序列。

内容的提问来源于stack exchange，提问作者user19668814