private _deliver(listener: undefined | UniqueContainer<(value: T) => void>, value: T) {
return;
}
const errorHandler = this._options?.onListenerError || onUnexpectedError;
if (!errorHandler) {
listener.value(value);
return;
}
try {
listener.value(value);
} catch (e) {
errorHandler(e);
}
/** Delivers items in the queue. Assumes the queue is ready to go. */