我无法让 Observable.FromEvent(...).ToEnumerable() 工作

Question

当我尝试从本机 .NET 事件创建的 IObservable 获取 IEnumerable 时，IEnumerable 在查询第一个元素时会阻塞。我做错了什么？

我已经构建了一个小型完整示例。尽管事件由另一个 IObservable 正确推送，但第一个测试方法会阻塞。第二种测试方法适用于普通数组并且不会阻塞。

谢谢！

using System;
using System.Linq;
using Microsoft.VisualStudio.TestTools.UnitTesting;

namespace TestGTI.Reactive
{

    class ItHappenedEventArgs : EventArgs
    {
    }

    class A
    {
        public event EventHandler<ItHappenedEventArgs> ItHappened;

        public void RaiseItHappened(ItHappenedEventArgs e)
        {
            if (ItHappened != null)
            {
                ItHappened(this, e);
            }
        }
    }

    [TestClass]
    public class ReactiveTest
    {
        [TestMethod]
        public void EnumerateEventTest()
        {
            var a = new A();

            ItHappenedEventArgs pushed = null;
            Observable.FromEvent<ItHappenedEventArgs>(a, "ItHappened").Subscribe(e =>
                {
                    pushed = e.EventArgs;
                });

            var itHappenedEnum = Observable.FromEvent<ItHappenedEventArgs>(a, "ItHappened").ToEnumerable();

            var itHappenedEventArgs = new ItHappenedEventArgs();
            a.RaiseItHappened(itHappenedEventArgs);

            Assert.AreSame(itHappenedEventArgs, pushed);

            // blocks!!!
            Assert.AreSame(itHappenedEventArgs, itHappenedEnum.First());        
        }

        [TestMethod]
        public void ObservableToEnumerableTest()
        {
            var array = new int[] { 1, 2, 3 };
            var enumerable = array.ToObservable().ToEnumerable();

            // works
            Assert.AreEqual(1, enumerable.First());
        }
    }
}

Answer 1

IEnumerable 在枚举方面是惰性的，而 ToEnumerable 在开始枚举之前不会订阅源。

在您的示例中，您在第一次引发事件之后调用 First() after ，因此您正在订阅源并且不会发出任何值，因此阻塞。基本上，当你在听的时候，价值已经来了又消失了。

如果您想记住该值，可以使用 Prune 或 Replay （记住连接到返回的 IConnectableObservable 来开始监听）。然后您可以使用 ToEnumerable 并且该值将被发出。

Answer 2

Richard 就在这里，但我还要从概念角度添加这一点 - IEnumerable 通常（在实践中，但不是必需的）是有限大小列表的抽象。 FromEvent 是一个永不终止的 IObservable - 创建无限大小的列表有意义吗？我能做的实际事情并不多......