ConcurrentReplayLatestSignalAsync class¶
Defined in
Namespace: ReactiveUI.Primitives.Async.Signals
Assembly: ReactiveUI.Primitives.Async.Core.dll
Full name: ReactiveUI.Primitives.Async.Signals.ConcurrentReplayLatestSignalAsync<T>
Modifiers: public sealed
Summary¶
Represents an asynchronous Signal that replays only the latest value to new observers and supports concurrent
notification of observers.
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 ConcurrentReplayLatestSignalAsync~T~
class ISignalAsync~T~ {
<>
}
ISignalAsync~T~ <|.. ConcurrentReplayLatestSignalAsync~T~
class IObserverAsync~T~ {
<>
}
IObserverAsync~T~ <|.. ConcurrentReplayLatestSignalAsync~T~
class IAsyncDisposable {
<>
}
IAsyncDisposable <|.. ConcurrentReplayLatestSignalAsync~T~
class IObservableAsync~T~ {
<>
}
IObservableAsync~T~ <|.. ConcurrentReplayLatestSignalAsync~T~
Implements: ISignalAsync
Remarks¶
This Signal notifies all observers concurrently, which can improve throughput in scenarios with multiple observers. The order in which observers receive notifications is not guaranteed. This type is thread-safe and suitable for use in asynchronous and concurrent environments.
Constructors¶
| Name | Summary |
|---|---|
| .ctor | Represents an asynchronous Signal that replays only the latest value to new observers and supports concurrent notification of observers. |
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. |