Rx 处理订阅

Question

处置循环中创建的订阅的推荐方法是什么？ 在下面的人为示例中，我在 for 循环中生成订阅并将它们添加到 List 并通过 List 这对我来说似乎有点臭，我认为必须有一种更清洁的方法来清理订阅，除非 GC 在运行时处理它们。我需要明确 Dispose 订阅吗？

class Program
{
    static void Main(string[] args)
    {
        Func<int, IEnumerable<int>> func = x =>
        {
            return Enumerable.Range(0, x);
        };

        List<IDisposable> subsriptions = new List<IDisposable>();
        for (int i = 1; i < 10; i++)
        {
            var observable = func(i).ToObservable().ToList();
            var subscription = observable.Subscribe(x => Console.WriteLine(x.Select(y => y.ToString()).Aggregate((s1, s2) => s1 + "," + s2)));
            subsriptions.Add(subscription);
        }
        Console.ReadLine();
        subsriptions.ForEach(s => s.Dispose());
    }
}

Answer 1

如果源完成，则不需要处置订阅。在您的示例中，如果您想在完成之前停止枚举 Range，您只会处置订阅。

即使在这种情况下，更常见的做法是使用终止订阅的运算符（如 Take、TakeWhile、TakeUntil）来处理订阅。

如果您确实想合并多个 IDisposable 订阅，CompositeDisposable 就是专为做到这一点而设计的：

CompositeDisposable subsriptions = new CompositeDisposable();

subscriptions.Add(Observable.Interval(TimeSpan.FromSeconds(1)).Subscribe());
subscriptions.Add(Observable.Interval(TimeSpan.FromSeconds(1)).Subscribe());
subscriptions.Add(Observable.Interval(TimeSpan.FromSeconds(1)).Subscribe());

subscriptions.Dispose();