IObservable.Create中subscribe参数返回的Action实际上是用于什么目的?

4

IObservable.Create的方法定义如下:

public static IObservable<TSource> Create<TSource>(
    Func<IObserver<TSource>, Action> subscribe
)

我知道当可观察对象被订阅时会调用该函数,这样我就可以在观察者上调用OnNext、OnError和OnComplete。但为什么我需要从subscribe参数返回一个Action,它什么时候会被调用呢?

3个回答

4

当取消订阅观察者时,它被称为。来源


1

当订阅被处理时,它会被调用。它存在的目的是让您可以处理您已分配的任何资源。


1

在Kent的回答之后,调用Create等同于调用CreateWithDisposable并将操作传递给Disposable.Create()


网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接