我有一个可观察对象IObservable<T>
/ ISubject<T>
,想通过使用SignalR返回它。SignalR有异步流的概念,您必须返回一个IAsyncEnumerable<T>
。
如何将IObservable<T>
转换为IAsyncEnumerable<T>
?
我有一个可观察对象IObservable<T>
/ ISubject<T>
,想通过使用SignalR返回它。SignalR有异步流的概念,您必须返回一个IAsyncEnumerable<T>
。
如何将IObservable<T>
转换为IAsyncEnumerable<T>
?