>
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 ForwardOnNextConcurrently<T>(ImmutableArray<IObserverAsync<T>> observers, T value, CancellationToken cancellationToken)
Summary: Forwards the specified value to all observers concurrently by invoking their OnNextAsync methods.
Type parameters
| Name | Description |
|---|---|
T | The type of the value to forward to the observers. |
Parameters
| Name | Type | Description |
|---|---|---|
observers | ImmutableArray | A read-only list of observers that will receive the value. Cannot be null. |
value | T | The value to forward to each observer. |
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 value to all observers. The task completes when all observers have processed the value.
Remarks
If the observers list is empty, the returned ValueTask is already completed. All OnNextAsync calls are started concurrently; exceptions from observers are aggregated in the returned task.