c# - 如何为 Observable 设置处置操作？

Question

我知道如何创建一个可观察对象并分配一个处理操作:

Observable.Create(o =>
{
    // o.OnNext etc.
    return Disposable.Create(() => { /* ... */ });
});

但现在我从查询语法中生成了一个可观察对象:

var observable = from x in otherObservable
                 select x;

如何为此类查询分配处理操作？

Answer 1

如果我理解正确，您希望在处理订阅时“链接”或“收听”。一种方法是使用 Finally IObservable<T> 的运营商，因此:

var ob = from x in Observable.Interval(TimeSpan.FromSeconds(1))
            select x;

// Use Finally to create an intermediate IObservable
var disposeSub = ob.Finally(() => Console.WriteLine("disposed"));

// Subscribe to the intermediate observable instead the original one
var yourSub    = disposeSub.Subscribe(Console.WriteLine);

// Wait for some numbers to print
Thread.Sleep(TimeSpan.FromSeconds(4));

// "disposed" will be written on the console at this point
yourSub.Dispose();

希望对您有所帮助!