The definition of the IObservable.Create method:
public static IObservable<TSource> Create<TSource>( Func<IObserver<TSource>, Action> subscribe )
I get the function to be called after signing the observable, where I can then call OnNext, OnError and OnComplete on the observer. But why should I return the action from the subscibe parameter and when will it be called?
source share