IObservable.Create的方法定义如下:
public static IObservable<TSource> Create<TSource>(
Func<IObserver<TSource>, Action> subscribe
)
我知道当可观察对象被订阅时会调用该函数,这样我就可以在观察者上调用OnNext、OnError和OnComplete。但为什么我需要从subscribe参数返回一个Action,它什么时候会被调用呢?
IObservable.Create的方法定义如下:
public static IObservable<TSource> Create<TSource>(
Func<IObserver<TSource>, Action> subscribe
)
我知道当可观察对象被订阅时会调用该函数,这样我就可以在观察者上调用OnNext、OnError和OnComplete。但为什么我需要从subscribe参数返回一个Action,它什么时候会被调用呢?