Skip to content

)}

ObservableBridgeExtensions.ToObservableAsync(IObservable) method

Defined in

Type: ObservableBridgeExtensions Namespace: ReactiveUI.Extensions.Async Assembly: ReactiveUI.Extensions.dll

Applies to

net10.0, net10.0-browserwasm1.0, net10.0-desktop1.0, net9.0, net9.0-browserwasm1.0, net9.0-desktop1.0, net8.0, net8.0-ios17.5, net8.0-maccatalyst17.5, net8.0-macos14.2, net8.0-macos14.5, net8.0-tvos17.2, netstandard2.1, net462, net481

public static IObservableAsync<T> ToObservableAsync<T>(this IObservable<T> source)

View source

Summary: Converts a classic IObservable sequence into an ObservableAsync that forwards all notifications through asynchronous observer callbacks.

Type parameters

NameDescription
TThe type of elements in the observable sequence.

Parameters

NameTypeDescription
sourceIObservableThe classic observable sequence to bridge. Cannot be null.

Returns: IObservableAsync -- An ObservableAsync that mirrors the source observable sequence.

Remarks

The returned async observable subscribes to the source IObservable when an async observer subscribes. Because IObservable notifications are synchronous, each OnNext/OnError/OnCompleted callback is awaited sequentially before the next notification is processed.

Disposing the async subscription also disposes the underlying IDisposable subscription to the source observable.

Exceptions

TypeCondition
System.ArgumentNullExceptionThrown if source is null.