Skip to content

ConcurrentSignalAsync class

Defined in

Namespace: ReactiveUI.Primitives.Async.Signals Assembly: ReactiveUI.Primitives.Async.Core.dll Full name: ReactiveUI.Primitives.Async.Signals.ConcurrentSignalAsync<T> Modifiers: public sealed

Summary

View source

Provides an asynchronous Signal that forwards notifications to observers concurrently.

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, net471

Class hierarchy
classDiagram
class ConcurrentSignalAsync~T~
class ISignalAsync~T~ {
    <>
}
ISignalAsync~T~ <|.. ConcurrentSignalAsync~T~
class IObserverAsync~T~ {
    <>
}
IObserverAsync~T~ <|.. ConcurrentSignalAsync~T~
class IAsyncDisposable {
    <>
}
IAsyncDisposable <|.. ConcurrentSignalAsync~T~
class IObservableAsync~T~ {
    <>
}
IObservableAsync~T~ <|.. ConcurrentSignalAsync~T~

Implements: ISignalAsync, IObserverAsync, IAsyncDisposable, IObservableAsync

Remarks

Observers are notified in parallel for each event. This class is suitable for scenarios where high throughput and concurrent notification of multiple observers are required. Thread safety is ensured for observer notification operations. Cancellation tokens can be used to cancel ongoing notification tasks.

Constructors

NameSummary
.ctor

Methods

NameSummary
OnNextAsyncAsynchronously processes the next value in the sequence.
OnErrorResumeAsyncHandles the specified error and resumes asynchronous processing, if possible.
OnCompletedAsyncPerforms asynchronous completion logic in response to the specified result.
DisposeAsync
SubscribeAsyncSubscribes the specified asynchronous observer to receive notifications from the observable sequence.
Inherited members