ConcurrentStatelessSignalAsync class¶
Defined in
Namespace: ReactiveUI.Primitives.Async.Signals
Assembly: ReactiveUI.Primitives.Async.Core.dll
Full name: ReactiveUI.Primitives.Async.Signals.ConcurrentStatelessSignalAsync<T>
Modifiers: public sealed
Summary¶
Represents a stateless 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 ConcurrentStatelessSignalAsync~T~
class ISignalAsync~T~ {
<>
}
ISignalAsync~T~ <|.. ConcurrentStatelessSignalAsync~T~
class IObserverAsync~T~ {
<>
}
IObserverAsync~T~ <|.. ConcurrentStatelessSignalAsync~T~
class IAsyncDisposable {
<>
}
IAsyncDisposable <|.. ConcurrentStatelessSignalAsync~T~
class IObservableAsync~T~ {
<>
}
IObservableAsync~T~ <|.. ConcurrentStatelessSignalAsync~T~
Implements: ISignalAsync
Remarks¶
This Signal distributes notifications to all subscribed observers in parallel, allowing for improved throughput in scenarios where observer processing can occur independently. Use this type when observer notification order is not important and concurrent delivery is desired. Thread safety is ensured for concurrent observer notifications.
Constructors¶
| Name | Summary |
|---|---|
| .ctor |
Methods¶
| Name | Summary |
|---|---|
| OnNextAsync | Asynchronously processes the next value in the sequence. |
| OnErrorResumeAsync | Handles the specified error and resumes asynchronous processing, if possible. |
| OnCompletedAsync | Performs asynchronous completion logic in response to the specified result. |
| DisposeAsync | |
| SubscribeAsync | Subscribes the specified asynchronous observer to receive notifications from the observable sequence. |