將非同步方法包裝為 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))