Namespace ReactiveUI.Extensions.Async.Subjects
Classes
- BaseReplayLatestSubjectAsync<T>
Provides a base implementation for an asynchronous subject that replays the latest value to new subscribers and supports asynchronous notification of observers.
- BaseStatelessReplayLastSubjectAsync<T>
Provides a base class for stateless, asynchronous subjects that replay the last value to new subscribers and support resuming after errors or completion. Designed for scenarios where observers may join at any time and should receive the most recent value, if available.
- BaseStatelessSubjectAsync<T>
Provides a base class for implementing asynchronous, stateless subjects that broadcast notifications to multiple observers. Supports asynchronous notification, error handling, and completion signaling for observers subscribing to the subject.
- BaseSubjectAsync<T>
Provides a base class for asynchronous subjects that support both publishing values to observers and receiving values asynchronously.
- BehaviorSubjectCreationOptions
Represents configuration options for creating a behavior subject, including publishing behavior and statefulness.
- Concurrent
Provides helper methods for forwarding asynchronous observer notifications concurrently to multiple observers.
- ConcurrentReplayLatestSubjectAsync<T>
Represents an asynchronous subject that replays only the latest value to new observers and supports concurrent notification of observers.
- ConcurrentStatelessReplayLatestSubjectAsync<T>
Represents an asynchronous subject that replays the latest value to new observers and forwards notifications to all observers concurrently without maintaining internal state.
- ConcurrentStatelessSubjectAsync<T>
Represents a stateless asynchronous subject that forwards notifications to observers concurrently.
- ConcurrentSubjectAsync<T>
Provides an asynchronous subject that forwards notifications to observers concurrently.
- ReplayLatestSubjectCreationOptions
Represents configuration options for creating a replay-latest subject, controlling publishing behavior and state retention.
- SerialReplayLatestSubjectAsync<T>
Represents an asynchronous subject that replays only the latest value to new subscribers and ensures that notifications are delivered to observers in a serial, thread-safe manner.
- SerialStatelessReplayLastSubjectAsync<T>
Represents a serial, stateless asynchronous subject that replays only the last value to new observers and supports asynchronous notification delivery.
- SerialStatelessSubjectAsync<T>
Represents a stateless asynchronous subject that notifies observers of events in a serial, sequential manner.
- SerialSubjectAsync<T>
Represents an asynchronous subject that notifies observers in a serial manner, ensuring each observer is notified one at a time.
- SubjectAsync
Provides factory methods for creating asynchronous subject instances with configurable publishing and state retention behaviors.
- SubjectCreationOptions
Represents the set of options used when creating a subject, including publishing behavior and state management requirements.
Interfaces
- ISubjectAsync<T>
Represents an asynchronous subject that allows observers to receive values, errors, or completion notifications asynchronously.
Enums
- PublishingOption
Specifies the available options for publishing operations, indicating whether actions are performed serially or concurrently.