system.reactive 将异步方法包装为可观察的

示例

给定这样的async方法:

Task<string> GetNameAsync(CancellationToken cancellationToken)

IObservable<string>像这样包装它:

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