Menu
I have an observable IObservable<T> / ISubject<T> and want to return that by using SignalR. SignalR has the concept of async streams where you have to return an IAsyncEnumerable<T>.
How can I transform an IObservable<T> to an IAsyncEnumerable<T>?
607
If one has an IEnumerable of unknown type, there are two ways one can "convert it to IObservable": Copy all of the data in the object to a new collection which implements IObservable. If this is done, only changes made to the new collection will be reported. Changes made to the original will not.
The IObservable<T> interface represents the class that sends notifications (the provider); the IObserver<T> interface represents the class that receives them (the observer). T represents the class that provides the notification information. In some push-based notifications, the IObserver<T> implementation and T can represent the same type.
The IObservable<T> interface does not make any assumptions about the number of observers or the order in which notifications are sent. The provider sends the following three kinds of notifications to the observer by calling IObserver<T> methods: The current data.
The way you could leverage IAsyncEnumerable<T> on the client is if that client is invoking some kind of streaming or making multiple requests to a server for a unique list of results (paging). Thanks for contributing an answer to Stack Overflow!
There is a ToAsyncEnumerable extension method in the System.Linq.Async assembly, available as a NuGet package here.
public static IAsyncEnumerable<TSource> ToAsyncEnumerable<TSource>(
this IObservable<TSource> source);
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With
