WitnessAsync class¶

Summary¶

View source

Represents an asynchronous observer that processes notifications of type T using asynchronous methods.

classDiagram
class WitnessAsync~T~
class IObserverAsync~T~ {
    <>
}
IObserverAsync~T~ <|.. WitnessAsync~T~
class IAsyncDisposable {
    <>
}
IAsyncDisposable <|.. WitnessAsync~T~
class IReentrantAsyncDisposable {
    <>
}
IReentrantAsyncDisposable <|.. WitnessAsync~T~

Implements: IObserverAsync, IAsyncDisposable, IReentrantAsyncDisposable

Remarks¶

Implement this abstract class to handle asynchronous event streams or push-based data sources, where notifications may arrive concurrently or in rapid succession. The observer provides asynchronous methods for handling new data, errors, and completion signals, and supports proper resource cleanup via asynchronous disposal. Instances are not thread-safe for concurrent notification handling; notifications are processed sequentially, and reentrant calls are detected and reported as unhandled exceptions.

Constructors¶

Methods¶