是否有可能将IObservable 转换为IAsyncEnumerable ] >> 我有一个可观察的IObservable<T> / ISubject<T>，并想通过使用SignalR将其返回。 SignalR具有异步流的概念，您必须在其中返回IAsyncEnumerable<T>。 如何将IObservable<T>转换为IAsyncEnumerable<T>？ 我有一个可观察的IObservable / ISubject ，并想通过使用SignalR返回它。 SignalR具有异步流的概念，您必须在其中返回IAsyncEnumerable 。 ...

Question

我有一个可观察的IObservable<T> / ISubject<T>，并想通过使用SignalR将其返回。 SignalR具有异步流的概念，您必须在其中返回IAsyncEnumerable<T>。

如何将IObservable<T>转换为IAsyncEnumerable<T>？

我有一个可观察的IObservable / ISubject ，并想通过使用SignalR返回它。 SignalR具有异步流的概念，您必须在其中返回IAsyncEnumerable 。 ...

Answer 1

ToAsyncEnumerable程序集中有一个System.Linq.Async扩展方法，可以作为NuGet包here使用。

public static IAsyncEnumerable<TSource> ToAsyncEnumerable<TSource>(
    this IObservable<TSource> source);