Skip to content

ConcurrentStatelessReplayLatestSignalAsync class

Defined in

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

Summary

View source

        Represents an asynchronous Signal that replays the latest value to new observers and forwards notifications to all
        observers concurrently without maintaining internal state.
        

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 ConcurrentStatelessReplayLatestSignalAsync~T~
class ISignalAsync~T~ {
    <>
}
ISignalAsync~T~ <|.. ConcurrentStatelessReplayLatestSignalAsync~T~
class IObserverAsync~T~ {
    <>
}
IObserverAsync~T~ <|.. ConcurrentStatelessReplayLatestSignalAsync~T~
class IAsyncDisposable {
    <>
}
IAsyncDisposable <|.. ConcurrentStatelessReplayLatestSignalAsync~T~
class IObservableAsync~T~ {
    <>
}
IObservableAsync~T~ <|.. ConcurrentStatelessReplayLatestSignalAsync~T~

Implements: ISignalAsync, IObserverAsync, IAsyncDisposable, IObservableAsync

Remarks

This Signal is designed for concurrent scenarios where notifications to observers should be delivered in parallel. It does not buffer or store a sequence of values, but only replays the most recent value (if any) to new subscribers. Thread safety is ensured for concurrent observer notifications. If a notification operation is canceled, not all observers may receive the notification.

Constructors

NameSummary
.ctorRepresents an asynchronous Signal that replays the latest value to new observers and forwards notifications to all observers concurrently without maintaining internal state.

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