>
Defined in Type: Concurrent
Namespace: ReactiveUI.Extensions.Async.Subjects
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 ValueTask ForwardOnErrorResumeConcurrently<T>(ImmutableArray<IObserverAsync<T>> observers, Exception error, CancellationToken cancellationToken)
Summary: Forwards an error notification to all specified asynchronous observers concurrently, allowing each observer to handle the error and resume as appropriate.
Type parameters
| Name | Description |
|---|---|
T | The type of the elements observed by the observers. |
Parameters
| Name | Type | Description |
|---|---|---|
observers | ImmutableArray | A read-only list of asynchronous observers to which the error notification will be forwarded. Cannot be null. |
error | Exception | The exception representing the error to forward to each observer. Cannot be null. |
cancellationToken | CancellationToken | A cancellation token that can be used to cancel the forwarding operation. |
Returns: ValueTask -- A ValueTask that represents the asynchronous operation of forwarding the error to all observers. The task completes when all observers have processed the error notification.
Remarks
If the list of observers is empty, the method returns a default ValueTask and no notifications are sent. Each observer receives the error notification concurrently. If cancellation is requested via the cancellation token, the operation may be canceled before completion.