BaseStatelessSubjectAsync class¶

Summary¶

View source

        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.
        

classDiagram
class BaseStatelessSubjectAsync~T~
class ObservableAsync~T~
ObservableAsync~T~ <|-- BaseStatelessSubjectAsync~T~
class ISubjectAsync~T~ {
    <>
}
ISubjectAsync~T~ <|.. BaseStatelessSubjectAsync~T~
class IObserverAsync~T~ {
    <>
}
IObserverAsync~T~ <|.. BaseStatelessSubjectAsync~T~
class IAsyncDisposable {
    <>
}
IAsyncDisposable <|.. BaseStatelessSubjectAsync~T~
class IObservableAsync~T~ {
    <>
}
IObservableAsync~T~ <|.. BaseStatelessSubjectAsync~T~

Inherits from: ObservableAsync

Implements: ISubjectAsync, IObserverAsync, IAsyncDisposable, IObservableAsync

Remarks¶

This abstract class enables the creation of custom asynchronous subjects that do not maintain internal state between notifications. It manages observer subscriptions and provides extensibility points for handling value notifications, error recovery, and completion events. Implementations should override the core notification methods to define specific broadcasting or error-handling behaviors. Thread safety and observer management are handled by the base class, allowing derived classes to focus on notification logic.

Constructors¶

Methods¶