使用 Observable.FromEvent 创建的 observable 何时会与事件生产者分离？

Question

更新：发现类似的问题： Rx - 取消订阅事件

给出代码：

interface IBitmapCapturer {
    event EventHandler<EventArgs<RawBitmap>> Captured;
    void Start();
    void Stop();
}

public class Camera {
    IBitmapCapturer m_capturer;

    public RawBitmap CaptureBitmap() {
        IObservable<IEvent<EventArgs<RawBitmap>>> observable = Observable.FromEvent<EventArgs<RawBitmap>>(
            handler => m_capturer.Captured += handler,
            handler => m_capturer.Captured -= handler);
        m_capturer.Start();
        IEvent<EventArgs<RawBitmap>> evn = observable.First();
        m_capturer.Stop();
        return evn.EventArgs.EventData;
    }
}

我在做什么这是从相机拍摄的一张照片，但也是唯一的第一个。 IBitmapCapturer是一些与DirectShow相关的东西，不提供“拍摄”的方法，仅生成带有位图的事件。因此，我使用反应式扩展来获取第一个事件并取消订阅。 我的疑问是关于“observable.First()”行。

我是否正确理解在调用 observable.First() 之后我的 observable 与 m_capturer （事件生成器）分离？如果不是，那么我如何确保 m_capturer.Captured 上没有订阅者？

Answer 1

该框架确保在序列完成或出错时处理从 Subscribe 返回的 IDisposable 值，以及由 FromEvent 返回的 IDisposable 值 取消订阅该事件。

由于 First 是 Take(1) 的阻塞实现，因此源序列将在收到第一个值后（或者当源为空时抛出异常后）被处理）。

简而言之，您可以确定在对 First 的调用完成后，事件处理程序将被删除。