ReactiveUI.Primitives.Async.Advanced namespace¶

Part of the ReactiveUI.Primitives.Async.Core package.

Type	Kind	Summary
AsyncEnumerableSignal	class	An observable that emits values from an asynchronous enumerable for each subscription.
AsyncEnumerableSubscription	class	A subscription that emits the contents of an asynchronous enumerable.
AsyncSerialGate	class	Asynchronous mutual-exclusion primitive that serializes critical sections in the async pipeline. Uncontended acquire is a pure CompareExchange (no SemaphoreSlim touch); the contended path waits on a signal-only semaphore and retries the CAS after each signal. Same-thread reentry is granted via the owner-thread-id and a recursion counter.
BackgroundJobSignal	class	An observable that runs a supplied asynchronous job for each subscription.
CallbackWitnessAsync	class	An witness that routes notifications through user-supplied asynchronous callbacks.
DoOnSubscribeAsyncSignal	class	An observable that invokes an asynchronous side effect before subscribing to its source.
DoOnSubscribeSignal	class	An observable that invokes a synchronous side effect before subscribing to its source.
EnumerableSignal	class	An observable that emits values from an enumerable for each subscription.
EnumerableSubscription	class	A subscription that emits the contents of an enumerable.
FlatMapCoordinator	class	Coordinates outer and inner subscriptions for flat-map operations.
FlatMapSignal	class	An observable that projects source values to inner observables and merges those inner observables.
FlatMapWitness	class	Outer observer that projects source values to inner observables.
FlatMapWitness	class	Inner observer that relays projected values to a flat-map coordinator.
ForwardingWitnessAsync	class	Base observer that forwards every notification to a downstream observer.
FromAsyncSignal	class	An observable that invokes an asynchronous value factory for each subscription.
FromAsyncSubscription	class	A subscription that invokes an asynchronous value factory and emits its result.
IReentrantAsyncDisposable	interface	An async-disposable that can be disposed from within its own in-flight notification.
IntervalSignal	class	An observable that emits incrementing ticks at a fixed interval.
IntervalSubscription	class	A subscription that emits incrementing ticks at a fixed interval.
LeadSignal	class	An observable that emits leading values before subscribing to the source sequence.
LeadSubscription	class	Subscription that emits leading values and then relays the source sequence.
Lease	struct	Releases a previously acquired [AsyncSerialGate](# when disposed.
LogErrorsSignal	class	An observable that logs resumable errors without changing the source sequence.
LogErrorsWitness	class	An observer that logs resumable errors before forwarding them downstream.
PooledDelaySource	class	Poolable IValueTaskSource used by `DelayAsync` for the non-System TimeProvider code path. Replaces the per-call TaskCompletionSource + Task + CancellationTokenRegistration allocation chain with a rented-then-returned instance. The wrapped ManualResetValueTaskSourceCore is the standard poolable async-primitive shape from `System.Threading.Tasks.Sources`.
ReattemptSignal	class	An observable that resubscribes to the source after terminal failures.
ReattemptSubscription	class	Coordinates retry subscriptions for [ReattemptSignal](#
ReattemptWitness	class	Observer for a single retry attempt.
RelayWitnessAsync	class	Relays notifications from the base observer pipeline to another asynchronous observer.
SequenceSignal	class	An observable that emits a contiguous integer sequence for each subscription.
SequenceSubscription	class	A subscription that emits a contiguous integer sequence.
SingleElementWitness	class	Shared observer used by both `SingleAsync` and `SingleOrDefaultAsync`. The two operator surfaces previously held near-identical observer classes; the only behavioural difference is whether an empty sequence throws or returns a caller-supplied default. That difference is now a single flag on this type, so the OnNext / OnErrorResume / OnCompleted bodies live in one place.
StartSignal	class	An observable that invokes a synchronous function and emits its result for each subscription.
StartSubscription	class	A subscription that invokes a synchronous function and emits its result.
SyncLatest10Coordinator	class	Coordinates subscriptions and latest-value emission for the arity-10 `SyncLatest` operator.
SyncLatest10Signal	class	Async observable that combines the latest values from ten source sequences using a selector.
SyncLatest10State	struct	Bundles the source observables for the arity-10 `SyncLatest` operator.
SyncLatest11Coordinator	class	Coordinates subscriptions and latest-value emission for the arity-11 `SyncLatest` operator.
SyncLatest11Signal	class	Async observable that combines the latest values from eleven source sequences using a selector.
SyncLatest11State	struct	Bundles the source observables for the arity-11 `SyncLatest` operator.
SyncLatest12Coordinator	class	Coordinates subscriptions and latest-value emission for the arity-12 `SyncLatest` operator.
SyncLatest12Signal	class	Async observable that combines the latest values from twelve source sequences using a selector.
SyncLatest12State	struct	Bundles the source observables for the arity-12 `SyncLatest` operator.
SyncLatest13Coordinator	class	Coordinates subscriptions and latest-value emission for the arity-13 `SyncLatest` operator.
SyncLatest13Signal	class	Async observable that combines the latest values from thirteen source sequences using a selector.
SyncLatest13State	struct	Bundles the source observables for the arity-13 `SyncLatest` operator.
SyncLatest14Coordinator	class	Coordinates subscriptions and latest-value emission for the arity-14 `SyncLatest` operator.
SyncLatest14Signal	class	Async observable that combines the latest values from fourteen source sequences using a selector.
SyncLatest14State	struct	Bundles the source observables for the arity-14 `SyncLatest` operator.
SyncLatest15Coordinator	class	Coordinates subscriptions and latest-value emission for the arity-15 `SyncLatest` operator.
SyncLatest15Signal	class	Async observable that combines the latest values from fifteen source sequences using a selector.
SyncLatest15State	struct	Bundles the source observables for the arity-15 `SyncLatest` operator.
SyncLatest16Coordinator	class	Coordinates subscriptions and latest-value emission for the arity-16 `SyncLatest` operator.
SyncLatest16Signal	class	Async observable that combines the latest values from sixteen source sequences using a selector.
SyncLatest16State	struct	Bundles the source observables for the arity-16 `SyncLatest` operator.
SyncLatest2Coordinator	class	Coordinates subscriptions and latest-value emission for the arity-2 `SyncLatest` operator.
SyncLatest2Signal	class	Async observable that combines the latest values from two source sequences using a selector.
SyncLatest2State	struct	Bundles the source observables for the arity-2 `SyncLatest` operator.
SyncLatest3Coordinator	class	Coordinates subscriptions and latest-value emission for the arity-3 `SyncLatest` operator.
SyncLatest3Signal	class	Async observable that combines the latest values from three source sequences using a selector.
SyncLatest3State	struct	Bundles the source observables for the arity-3 `SyncLatest` operator.
SyncLatest4Coordinator	class	Coordinates subscriptions and latest-value emission for the arity-4 `SyncLatest` operator.
SyncLatest4Signal	class	Async observable that combines the latest values from four source sequences using a selector.
SyncLatest4State	struct	Bundles the source observables for the arity-4 `SyncLatest` operator.
SyncLatest5Coordinator	class	Coordinates subscriptions and latest-value emission for the arity-5 `SyncLatest` operator.
SyncLatest5Signal	class	Async observable that combines the latest values from five source sequences using a selector.
SyncLatest5State	struct	Bundles the source observables for the arity-5 `SyncLatest` operator.
SyncLatest6Coordinator	class	Coordinates subscriptions and latest-value emission for the arity-6 `SyncLatest` operator.
SyncLatest6Signal	class	Async observable that combines the latest values from six source sequences using a selector.
SyncLatest6State	struct	Bundles the source observables for the arity-6 `SyncLatest` operator.
SyncLatest7Coordinator	class	Coordinates subscriptions and latest-value emission for the arity-7 `SyncLatest` operator.
SyncLatest7Signal	class	Async observable that combines the latest values from seven source sequences using a selector.
SyncLatest7State	struct	Bundles the source observables for the arity-7 `SyncLatest` operator.
SyncLatest8Coordinator	class	Coordinates subscriptions and latest-value emission for the arity-8 `SyncLatest` operator.
SyncLatest8Signal	class	Async observable that combines the latest values from eight source sequences using a selector.
SyncLatest8State	struct	Bundles the source observables for the arity-8 `SyncLatest` operator.
SyncLatest9Coordinator	class	Coordinates subscriptions and latest-value emission for the arity-9 `SyncLatest` operator.
SyncLatest9Signal	class	Async observable that combines the latest values from nine source sequences using a selector.
SyncLatest9State	struct	Bundles the source observables for the arity-9 `SyncLatest` operator.
SyncLatestCoordinatorBase	class	Shared scaffolding for the arity-specific `CombineLatestN` subscription types. Each per-arity `SyncLatestCoordinator` derives from this class so the otherwise-identical [SyncLatestLifecycle](# wiring (gate / dispose CTS / external link), the values-lock, the source-subscribe loop, the error-resume forwarder, and [DisposeAsync](# live here once instead of repeated 15× across `CombineLatest2..16`.
SyncLatestEnumerableCoordinator	class	Coordinates subscriptions and projected snapshot emission for enumerable `SyncLatest` sources.
SyncLatestEnumerableSignal	class	Async observable that combines latest values from an enumerable of sources and projects through a selector.
SyncLatestEnumerableWitness	class	Per-source observer for enumerable `SyncLatest` sources.
SyncLatestIndexedWitness	class	Per-source [WitnessAsync](# used by every `CombineLatestN` subscription. The per-arity class previously declared N hand-rolled `OnNextN` / `OnCompletedN` method pairs whose bodies differed only in which `Optional<TN>` field they wrote and which completion bit they passed to the lifecycle. Pre-building N of these witnesses at subscription time keeps the typing exact and eliminates the per-source method declarations from the per-arity files. The closure cost (one delegate per source for the value-write) is paid once at subscribe and not per emission; the actual per-emission cost is one indirect delegate invoke under the values-lock.
SyncLatestLifecycle	class	Shared subscription lifecycle for the arity-specific `CombineLatestN` operators (2..16) and the enumerable variant. Each per-arity `SyncLatestCoordinator` composes one instance of this class (has-a, not is-a) and forwards lifecycle / error / gating work into it, so the previously-duplicated infrastructure (gate, dispose CTS, external-link registration, observer fan-out, completion-bitmask handling) lives in one place.
SyncLatestWitness	class	Per-source observer used by arity-specific `SyncLatest` coordinators to record typed source values and forward source terminal notifications to the shared lifecycle.
TakeUntilLifecycle	class	Shared subscription lifecycle for the TakeUntil family of operators (CancellationToken / Task / raw-signal / async-observable / async-predicate variants). Each per-trigger Subscription composes one instance of this class (has-a, not is-a) and forwards forward-on-next / -error / -completed plus external-cancellation linking into it, so the previously-duplicated infrastructure (gate, dispose CTS, external-link registration, gated observer fan-out) lives in one place.
TakeUntilSourceWitness	class	Shared [WitnessAsync](# implementation that forwards every source notification straight into a [TakeUntilLifecycle](# instance. Used by every per-trigger TakeUntil Subscription so the per-operator inner-class shells (which previously held identical three-method forwarders) collapse into a single shared type.
TaskResultCompletionSource	class	Coordinates task completion for terminal observers and disposes the owning subscription when complete.
TaskResultSignal	class	An observable that emits the result of a task for each subscription.
TaskResultSubscription	class	A subscription that awaits a task and emits its result.
TaskResultWitnessAsyncBase	class	Base class for witnesses that produce a single task-based result value when the observed sequence completes.
TaskSignalSubscription	class	Provides factory methods for creating and starting cancelable task-based subscriptions.
TaskSignalSubscription	class	Represents an asynchronous subscription that can be cancelled and disposed, managing the lifecycle of an observer and its associated operations.
TimerSignal	class	An observable that emits one or more timer ticks.
TimerSubscription	class	A subscription that emits one or more timer ticks.
UsingSignal	class	An observable that creates and disposes an asynchronous resource for each subscription.
UsingWitness	class	Observer that disposes a resource with the source subscription.