将异步方法包装为 observable
给定像这样的 async 方法:
Task<string> GetNameAsync(CancellationToken cancellationToken)
把它包装成像这样的 IObservable<string>:
Observable.FromAsync(cancellationToken => GetNameAsync(cancellationToken))
给定像这样的 async 方法:
Task<string> GetNameAsync(CancellationToken cancellationToken)
把它包装成像这样的 IObservable<string>:
Observable.FromAsync(cancellationToken => GetNameAsync(cancellationToken))