当对象处置时，请从事件中取消订阅

Question

我要弄清楚的是如何声明对象引用在将订阅处置为fromeventPattern时，在观察到的fromeventPattern时，将异常设置为异常。处置订阅之前，对象被处置。 这是一个简化的示例：

void Main()
{
    EventSource oEventSource = new();
    
    var source = Observable.FromEventPattern<MyEventArgs>(
                h => oEventSource.MyEvent += h,
                h => {
                    //if (oEventSource != null) 
                    oEventSource.MyEvent -= h; // <--- error thrown here
                })
        .Select(x => x.EventArgs.Value)
        .Subscribe(x => Console.WriteLine(x));

    Observable.Interval(TimeSpan.FromMilliseconds(500)).Subscribe(x =>
    {
        oEventSource?.RaiseMyEvent(x);
    });
        
    Thread.Sleep(3000);
    oEventSource = null;
    
    Thread.Sleep(2000);
    source.Dispose(); // <--- error thrown when disposing subscription
}


public class EventSource
{
    public event EventHandler<MyEventArgs> MyEvent;
    
    public void RaiseMyEvent(long x){
        MyEvent?.Invoke(this, new MyEventArgs(x));
    }
}

public class MyEventArgs : EventArgs
{
    public MyEventArgs(long x) { Value = x;}
    public long Value { get; set; }
}

我无法确保在处理“ Eventsource”对象之前处置订阅，因为该对象是在ViewModel中定义的，并且与订阅发生的视图绑定在一起。

在删除处理程序之前检查Eventsource对象是否存在停止升高的错误（if（oeventsource！= null）），但是由于处理程序从未被删除，它不会引入内存泄漏吗？

Answer 1

您的逻辑有很多混乱，您的样式并没有真正使用RX EG序列合成性。但是，对您的问题的答案是简单地订阅您的来源Uppon您想要的条件

.Select(x => x.EventArgs.Value)
    .TakeUntil(l => oEventSource!=null)  //this line
    .Subscribe(x => Console.WriteLine(x));