c# - react 性扩展 : Zip operator but different

Question

这不是现实生活中的例子(这段代码可能无法编译)但我试图让它比我实际遇到的问题简单一点。

假设我有图像集合:

private void IEnumerable<Image> GetImages()
{
    foreach (var filename in GetFilenames())
    {
         yield return Image.LoadFile(filename);
    }
}

我想展示由用户按“空格”驱动的幻灯片:

var images = Observable.FromEvent(form, "KeyPress")
  .Where(e => e.KeyCode == KeyCode.Space)
  .Zip(GetImages.ToObservable(), (k, i) => i);

还有这种作品。当按下空格时，它会发出下一张图像。问题是它实际上以全速加载它们，因此它们会被缓冲并消耗大量内存(以及加载时的处理能力)。 我可以将过滤按键输入到 GetImages 并在那里进行压缩，但我不会保留 GetImages 的纯度。

有什么办法可以防止enumerable.ToObservable()在不需要的情况下被提前枚举？

另一个例子(这个会编译):

var observable = 
    Observable.Interval(TimeSpan.FromSeconds(1))
    .Zip(
        Observable.Range(0, 1000000).Do(x => Console.WriteLine("produced {0}", x)), 
        (_, v) => v
    );

var subscription = observable.Subscribe(x => Console.WriteLine("consumed {0}", x));

Console.WriteLine("Press <enter>...");
Console.ReadLine();

它会产生很多“produced”(提前)但每秒只有一个“consumed”。

Answer 1

Dave 坚持从 IEnumerable<T> 中提取图像的想法是可靠的，但您可以更轻松地实现相同的目标 - 只需删除 ToObservable()从你的代码:

var images = Observable.FromEvent(form, "KeyPress")
                       .Where(e => e.KeyCode == KeyCode.Space)
                       .Zip(GetImages() /* No ToObservable() here! */, (k, i) => i);

Zip 的这种重载将在您按键时驱动图像可枚举。