,System.Threading.CancellationToken,System.Threading.Tasks.ValueTask{System.IAsyncDisposable>
Defined in Type: ObservableAsync
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> Create<T>(Func<IObserverAsync<T>, CancellationToken, ValueTask<IAsyncDisposable>> subscribeAsync)
Summary: Creates a new asynchronous observable sequence using the specified subscription function.
Type parameters
| Name | Description |
|---|---|
T | The type of the elements produced by the observable sequence. |
Parameters
| Name | Type | Description |
|---|---|---|
subscribeAsync | Func | A function that is invoked when an observer subscribes to the sequence. The function receives an asynchronous observer and a cancellation token, and returns a task that yields a disposable resource representing the subscription. |
Returns: IObservableAsync
Remarks
The subscription function is responsible for handling observer notifications and managing the lifetime of the subscription. The returned disposable should release any resources or cancel ongoing operations when disposed.
Exceptions
| Type | Condition |
|---|---|
| System.ArgumentNullException | Thrown if subscribeAsync is null. |