Skip to content

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

View source

        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, IObserverAsync, IAsyncDisposable, IObservableAsync

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

NameSummary
.ctorRepresents an asynchronous Signal that replays only the latest value to new observers and supports concurrent notification of observers.

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