Class ObservableEventInvocable<T>

Namespace

WebDriverBiDi

Assembly

WebDriverBiDi.dll

Producer-side implementation of a subject in the Observer pattern for events, allowing a producer to notify observers.

public class ObservableEventInvocable<T> : ObservableEvent<T> where T : WebDriverBiDiEventArgs

Type Parameters

T

The type of event arguments containing information about the observable event.

Inheritance

object

ObservableEvent<T>

ObservableEventInvocable<T>

Inherited Members

ObservableEvent<T>.AddObserver(Action<T>, ObservableEventHandlerOptions, string)

ObservableEvent<T>.AddObserver(Func<T, Task>, ObservableEventHandlerOptions, string)

ObservableEvent<T>.AddDataCollector(Func<T, bool>, string)

ObservableEvent<T>.RemoveObserver(string)

ObservableEvent<T>.ToString()

ObservableEvent<T>.SetObserverErrorReporter(Func<EventObserverErrorInfo, Task>)

ObservableEvent<T>.NotifyObserversAsync(T)

ObservableEvent<T>.EventName

ObservableEvent<T>.MaxObserverCount

ObservableEvent<T>.CurrentObserverCount

ObservableEvent<T>.TimeProvider

object.GetType()

object.MemberwiseClone()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Extension Methods

ObservableEventExtensions.ToObservable<T>(ObservableEvent<T>)

Constructors

ObservableEventInvocable(string)

Initializes a new instance of the ObservableEventInvocable<T> class.

public ObservableEventInvocable(string eventName)

Parameters

eventName string

The name of the event.

ObservableEventInvocable(string, uint)

Initializes a new instance of the ObservableEventInvocable<T> class.

public ObservableEventInvocable(string eventName, uint maxObserverCount)

Parameters

eventName string

The name of the event.

maxObserverCount uint

The maximum number of handlers that may observe this event.

Methods

InvokeNotifyObserversAsync(T)

Asynchronously notifies observers when this observable event occurs. Each observer is notified independently; an exception thrown by one observer does not prevent subsequent observers from being notified. If exactly one observer throws, the original exception is rethrown. If multiple observers throw, an AggregateException containing all caught exceptions is thrown after all observers have been notified.

public Task InvokeNotifyObserversAsync(T notifyData)

Parameters

notifyData T

The data of the event.

Returns

Task

The task object representing the asynchronous operation.

Exceptions

AggregateException

Thrown when multiple observer handlers throw an exception.

InvokeSetObserverErrorReporter(Func<EventObserverErrorInfo, Task>)

Sets the reporter used to surface observer failures that occur after the handler has already returned to the caller. This is intended for producers that need to handle asynchronous observer errors outside the normal exception propagation path.

public void InvokeSetObserverErrorReporter(Func<EventObserverErrorInfo, Task> reporter)

Parameters

reporter Func<EventObserverErrorInfo, Task>

The reporter callback.