Определение метода IObservable.Create:
public static IObservable<TSource> Create<TSource>(
Func<IObserver<TSource>, Action> subscribe
)
Я получаю, что функция вызывается после подписки на наблюдаемое, где я могу затем вызвать OnNext, OnError и OnComplete для наблюдателя.Но зачем мне возвращать Action из параметра subscibe и когда он действительно будет вызван?