system.reactive Envolviendo un método asíncrono como un observable.


Ejemplo

Dado un método async como este:

Task<string> GetNameAsync(CancellationToken cancellationToken)

Envuélvalo como una IObservable<string> como esto:

Observable.FromAsync(cancellationToken => GetNameAsync(cancellationToken))