将异步方法包装为 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))