c# - react 性可观察订阅处置

Question

如果我可以访问一个我知道只会返回一个项目的 IObservable，这会起作用吗？这是最好的使用模式吗？

IDisposable disposable = null;
disposable = myObservable.Subscribe(x =>
  {
     DoThingWithItem(x);
     if (disposable != null)
     {
       disposable.Dispose();
     }
  });

Answer 1

Subscribe 扩展方法返回的可释放对象仅允许您在可观察对象自然结束之前手动取消订阅可观察对象。

如果 observable 完成 - 使用 OnCompleted 或 OnError - 那么订阅已经为你处理了。

试试这段代码:

var xs = Observable.Create<int>(o =>
{
    var d = Observable.Return(1).Subscribe(o);
    return Disposable.Create(() =>
    {
        Console.WriteLine("Disposed!");
        d.Dispose();
    });
});

var subscription = xs.Subscribe(x => Console.WriteLine(x));

如果你运行上面的代码，你会看到“Disposed!”当 Observable 完成时写入控制台，而无需在订阅上调用 .Dispose()。

需要注意的一件重要事情:垃圾收集器从不对可观察订阅调用 .Dispose()，因此您必须处理您的订阅，如果它们没有(或可能)没有)在您的订阅超出范围之前自然结束。

以这个为例:

var wc = new WebClient();

var ds = Observable
    .FromEventPattern<
        DownloadStringCompletedEventHandler,
        DownloadStringCompletedEventArgs>(
            h => wc.DownloadStringCompleted += h,
            h => wc.DownloadStringCompleted -= h);

var subscription =
    ds.Subscribe(d =>
        Console.WriteLine(d.EventArgs.Result));

ds observable 只会在有订阅时附加到事件处理程序，并且只会在 observable 完成或订阅被销毁时分离。由于它是一个事件处理程序，因此 observable 永远不会完成，因为它正在等待更多事件，因此处理是从事件中分离的唯一方法(对于上面的示例)。

当你有一个你知道只会返回一个值的 FromEventPattern observable 时，明智的做法是在订阅之前添加 .Take(1) 扩展方法以允许事件处理程序自动分离，然后您无需手动处理订阅。

像这样:

var ds = Observable
    .FromEventPattern<
        DownloadStringCompletedEventHandler,
        DownloadStringCompletedEventArgs>(
            h => wc.DownloadStringCompleted += h,
            h => wc.DownloadStringCompleted -= h)
    .Take(1);

希望对您有所帮助。