.NET Rx中Observable.FromEventPattern未触发OnCompleted的问题排查及订阅释放疑问

嗨，我来帮你捋捋这两个问题哈～

一、为什么OnCompleted没触发？ #

首先得明确：用Observable.FromEventPattern创建的Observable默认是不会自动触发OnCompleted的！

为啥呢？因为Rx里的OnCompleted代表的是「这个Observable不会再发出任何新值了」，但事件源（比如你定义的DeviceEvent）本身是没有“终止”语义的——它可以一直触发下去（比如你一直按键盘，事件就会不断发生）。Rx根本不知道什么时候这个事件会停止，所以它不会主动帮你调用OnCompleted。从你终端的结果也能看出来，只有事件触发的打印，完全看不到OnCompleted的相关输出，本质就是这个原因。

那怎么让它触发OnCompleted呢？给你几个常见的方案：

• 用操作符限定结束条件：比如你希望按某个特定按键（比如Esc）就终止Observable，那可以用TakeUntil操作符，监听Esc键的输入信号，当Esc按下时，Observable就会触发OnCompleted。
• 手动控制完成信号：如果你能明确知道事件什么时候会停止（比如某个业务逻辑结束时），可以创建一个可控制的Subject，然后把DeviceEvent和这个Subject组合，当需要结束时调用Subject的OnCompleted，再用Merge或者TakeUntil来关联。
• 限定事件数量：如果只需要处理N次事件就结束，用Take(N)操作符，当收到N个事件后，自动触发OnCompleted。

二、关于在do while循环里Dispose订阅是否合适？ #

这个得分场景来看：

• 如果你的逻辑是每次循环都会创建新的Observable订阅（比如每次按键都重新绑定一次事件转Observable），那用完就调用Dispose是非常必要的！因为Rx的订阅会持有资源，不Dispose可能会导致内存泄漏，尤其是循环次数多的话。
• 但如果DeviceEvent是一个持续存在的事件源，其实更优的做法是只创建一次订阅，而不是每次循环都新建。比如把订阅逻辑放在循环外面，这样就不用反复Dispose和创建，效率更高。

举个贴合你场景的简单例子，假设你希望监听DeviceEvent直到Esc按下，同时处理每个事件：

public class MainApp
{
    public event EventHandler<DeviceEventArgs>? DeviceEvent;
    private ConsoleKeyInfo ch;

    public void Start()
    {
        // 将DeviceEvent转换为Observable
        var deviceObservable = Observable.FromEventPattern<DeviceEventArgs>(
            handler => DeviceEvent += handler,
            handler => DeviceEvent -= handler);

        // 创建监听Esc按键的Observable，作为终止信号
        var escTrigger = Observable.Create<Unit>(observer =>
        {
            Task.Run(() =>
            {
                while (true)
                {
                    var key = Console.ReadKey(true);
                    if (key.Key == ConsoleKey.Escape)
                    {
                        observer.OnNext(Unit.Default);
                        observer.OnCompleted();
                        break;
                    }
                    // 按下其他键时触发DeviceEvent
                    DeviceEvent?.Invoke(this, new DeviceEventArgs("测试设备"));
                }
            });
            return Disposable.Empty;
        });

        // 订阅：处理DeviceEvent，直到Esc按下触发完成
        var subscription = deviceObservable
            .TakeUntil(escTrigger)
            .Subscribe(
                evt => Console.WriteLine($"收到事件：{evt.EventArgs.DeviceName}"),
                ex => Console.WriteLine($"发生错误：{ex.Message}"),
                () => Console.WriteLine("OnCompleted 触发！")
            );

        Console.WriteLine("按任意键触发事件，按Esc退出...");
        // 等待任务完成
        escTrigger.Wait();

        // 释放订阅
        subscription.Dispose();
    }
}

public class DeviceEventArgs : EventArgs
{
    public string DeviceName { get; }
    public DeviceEventArgs(string deviceName) => DeviceName = deviceName;
}

这样调整后，当你按下Esc键时，TakeUntil会触发Observable的OnCompleted，同时订阅只创建一次，最后统一释放资源，逻辑更清晰也更高效。

备注：内容来源于stack exchange，提问作者Thanh Pham