ally {
      emitter[kCapture] = !0;
    }
}
var emitWithoutRejectionCapture = function emit(type, ...args) {
  if (type === "error")
    return emitError(this, args);
  var { _events: events } = this;
  if (events === @undefined)
    return !1;
  var handlers = events[type];
  if (handlers === @undefined)
    return !1;
  let maybeClonedHandlers = handlers.length > 1 ? handlers.slice() : handlers;
  for (let i = 0, { length } = maybeClonedHandlers;i < length; i++) {
    let handler = maybeClonedHandlers[i];
    switch (args.length) {
      case 0:
        handler.@call(this);
        break;
      case 1:
        handler.@call(this, args[0]);
        break;
      case 2:
        handler.@call(this, args[0], args[1]);
        break;
      case 3:
        handler.@call(this, args[0], args[1], args[2]);
        break;
      default:
        handler.@apply(this, args);
        break;
    }
  }
  return !0;
}, emitWithRejectionCapture = function emit2(type, ...args) {
  if (type === "error")
    return emitError(this, args);
  var { _events: events } = this;
  if (events === @undefined)
    return !1;
  var handlers = events[type];
  if (handlers === @undefined)
    return !1;
  let maybeClonedHandlers = handlers.length > 1 ? handlers.slice() : handlers;
  for (let i = 0, { length } = maybeClonedHandlers;i < length; i++) {
    let handler = maybeClonedHandlers[i], result;
    switch (args.length) {
      case 0:
        result = handler.@call(this);
        break;
      case 1:
        result = handler.@call(this, args[0]);
        break;
      case 2:
        result = handler.@call(this, args[0], args[1]);
        break;
      case 3:
        result = handler.@call(this, args[0], args[1], args[2]);
        break;
      default:
        result = handler.@apply(this, args);
        break;
    }
    if (result !== @undefined && @isPromise(result))
      addCatch(this, result, type, args);
  }
  return !0;
};
EventEmitterPrototype.emit = emitWithoutRejectionCapture;
EventEmitterPrototype.addListener = function addListener(type, fn) {
  checkListener(fn);
  var events = this._events;
  if (!events)
    events = this._events = Object.create(null), this._eventsCount = 0;
  else if (events.newListener)
    this.emit("newListener", type, fn.listener ?? fn);
  var handlers = events[type];
  if (!handlers)
    events[type] = [fn], this._eventsCount++;
  else {
    handlers.push(fn);
    var m = _getMaxListeners(this);
    if (m > 0 && handlers.length > m && !handlers.warned)
      overflowWarning(this, type, handlers);
  }
  return this;
};
EventEmitterPrototype.on = EventEmitterPrototype.addListener;
EventEmitterPrototype.prependListener = function prependListener(type, fn) {
  checkListener(fn);
  var events = this._events;
  if (!events)
    events = this._events = Object.create(null), this._eventsCount = 0;
  else if (events.newListener)
    this.emit("newListener", type, fn.listener ?? fn);
  var handlers = events[type];
  if (!handlers)
    events[type] = [fn], this._eventsCount++;
  else {
    handlers.unshift(fn);
    var m = _getMaxListeners(this);
    if (m > 0 && handlers.length > m && !handlers.warned)
      overflowWarning(this, type, handlers);
  }
  return this;
};
function overflowWarning(emitter, type, handlers) {
  if (!inspect)
    inspect = (@getInternalField(@internalModuleRegistry, 66) || @createInternalModuleById(66)).inspect;
  handlers.warned = !0;
  let warn = Error(`Possible EventTarget memory leak detected. ${handlers.length} ${@String(type)} listeners added to ${inspect(emitter, { depth: -1 })}. MaxListeners is ${emitter._maxListeners}. Use events.setMaxListeners() to increase limit`);
  warn.name = "MaxListenersExceededWarning", warn.emitter = emitter, warn.type = type, warn.count = handlers.length, process.emitWarning(warn);
}
function _onceWrap(target, type, listener) {
  let state = { fired: !1, wrapFn: @undefined, target, type, listener }, wrapped = onceWrapper.bind(state);
  return wrapped.listener = listener, state.wrapFn = wrapped, wrapped;
}
function onceWrapper() {
  if (!this.fired) {
    if (this.target.removeListener(this.type, this.wrapFn), this.fired = !0, arguments.length === 0)
      return this.listener.@call(this.target);
    return this.listener.@apply(this.target, arguments);
  }
}
EventEmitterPrototype.once = function once(type, fn) {
  return checkListener(fn), this.on(type, _onceWrap(this, type, fn)), this;
};
Object.defineProperty(EventEmitterPrototype.once, "name", { value: "once" });
EventEmitterPrototype.prependOnceListener = function prependOnceListener(type, fn) {
  return checkListener(fn), this.prependListener(type, _onceWrap(this, type, fn)), this;
};
EventEmitterPrototype.removeListener = function removeListener(type, listener) {
  checkListener(listener);
  let events = this._events;
  if (events === @undefined)
    return this;
  let list = events[type];
  if (list === @undefined)
    return this;
  let position = -1;
  for (let i = list.length - 1;i >= 0; i--)
    if (list[i] === listener || list[i].listener === listener) {
      position = i;
      break;
    }
  if (position < 0)
    return this;
  if (position === 0)
    list.shift();
  else
    ArrayPrototypeSplice.@call(list, position, 1);
  if (list.length === 0)
    delete events[type], this._eventsCount--;
  if (events.removeListener !== @undefined)
    this.emit("removeListener", type, listener.listener || listener);
  return this;
};
EventEmitterPrototype.off = EventEmitterPrototype.removeListener;
EventEmitterPrototype.removeAllListeners = function removeAllListeners(type) {
  let events = this._events;
  if (events === @undefined)
    return this;
  if (events.removeListener === @undefined) {
    if (type) {
      if (events[type])
        delete events[type], this._eventsCount--;
    } else
      this._events = Object.create(null);
    return this;
  }
  if (!type) {
    for (let key of ReflectOwnKeys(events)) {
      if (key === "removeListener")
        continue;
      this.removeAllListeners(key);
    }
    return this.removeAllListeners("removeListener"), this._events = Object.create(null), this._eventsCount = 0, this;
  }
  let listeners = events[type];
  if (listeners !== @undefined)
    for (let i = listeners.length - 1;i >= 0; i--)
      this.removeListener(type, listeners[i]);
  return this;
};
EventEmitterPrototype.listeners = function listeners(type) {
  var { _events: events } = this;
  if (!events)
    return [];
  var handlers = events[type];
  if (!handlers)
    return [];
  return handlers.map((x) => x.listener ?? x);
};
EventEmitterPrototype.rawListeners = function rawListeners(type) {
  var { _events } = this;
  if (!_events)
    return [];
  var handlers = _events[type];
  if (!handlers)
    return [];
  return handlers.slice();
};
EventEmitterPrototype.listenerCount = function listenerCount(type, method) {
  var { _events: events } = this;
  if (!events)
    return 0;
  if (method != null) {
    var length = 0;
    for (let handler of events[type] ?? [])
      if (handler === method || handler.listener === method)
        length++;
    return length;
  }
  return events[type]?.length ?? 0;
};
Object.defineProperty(EventEmitterPrototype.listenerCount, "name", { value: "listenerCount" });
EventEmitterPrototype.eventNames = function eventNames() {
  return this._eventsCount > 0 ? Reflect.ownKeys(this._events) : [];
};
EventEmitterPrototype[kCapture] = !1;
function once2(emitter, type, options = kEmptyObject) {
  validateObject(options, "options");
  var signal = options?.signal;
  if (validateAbortSignal(signal, "options.signal"), signal?.aborted)
    throw @makeAbortError(@undefined, { cause: signal?.reason });
  let { resolve, reject, promise } = @newPromiseCapability(@Promise), errorListener = (err) => {
    if (emitter.removeListener(type, resolver), signal != null)
      eventTargetAgnosticRemoveListener(signal, "abort", abortListener);
    reject(err);
  }, resolver = (...args) => {
    if (typeof emitter.removeListener === "function")
      emitter.removeListener("error", errorListener);
    if (signal != null)
      eventTargetAgnosticRemoveListener(signal, "abort", abortListener);
    resolve(args);
  };
  if (eventTargetAgnosticAddListener(emitter, type, resolver, { once: !0 }), type !== "error" && typeof emitter.once === "function")
    emitter.once("error", errorListener);
  function abortListener() {
    eventTargetAgnosticRemoveListener(emitter, type, resolver), eventTargetAgnosticRemoveListener(emitter, "error", errorListener), reject(@makeAbortError(@undefined, { cause: signal?.reason }));
  }
  if (signal != null)
    eventTargetAgnosticAddListener(signal, "abort", abortListener, { once: !0 });
  return promise;
}
Object.defineProperty(once2, "name", { value: "once" });
var AsyncIteratorPrototype = Object.getPrototypeOf(Object.getPrototypeOf(async function* () {}).prototype);
function createIterResult(value, done) {
  return { value, done };
}
function on(emitter, event, options = kEmptyObject) {
  validateObject(options, "options");
  let signal = options.signal;
  if (validateAbortSignal(signal, "options.signal"), signal?.aborted)
    throw @makeAbortError(@undefined, { cause: signal?.reason });
  let highWatermark = options.highWaterMark ?? options.highWatermark ?? Number.MAX_SAFE_INTEGER;
  validateInteger(highWatermark, "options.highWaterMark", 1);
  let lowWatermark = options.lowWaterMark ?? options.lowWatermark ?? 1;
  validateInteger(lowWatermark, "options.lowWaterMark", 1), FixedQueue ??= (@getInternalField(@internalModuleRegistry, 18) || @createInternalModuleById(18)).FixedQueue;
  let unconsumedEvents = new FixedQueue, unconsumedPromises = new FixedQueue, paused = !1, error = null, finished = !1, size = 0, iterator = Object.setPrototypeOf({
    next() {
      if (size) {
        let value = unconsumedEvents.shift();
        if (size--, paused && size < lowWatermark)
          emitter.resume(), paused = !1;
        return @Promise.@resolve(createIterResult(value, !1));
      }
      if (error) {
        let p = @Promise.@reject(error);
        return error = null, p;
      }
      if (finished)
        return closeHandler();
      return new @Promise(function(resolve, reject) {
        unconsumedPromises.push({ resolve, reject });
      });
    },
    return() {
      return closeHandler();
    },
    throw(err) {
      if (!err || !(err instanceof Error))
        throw @makeErrorWithCode(118, "EventEmitter.AsyncIterator", "Error", err);
      errorHandler(err);
    },
    [Symbol.asyncIterator]() {
      return this;
    },
    [kWatermarkData]: {
      get size() {
        return size;
      },
      get low() {
        return lowWatermark;
      },
      get high() {
        return highWatermark;
      },
      get isPaused() {
        return paused;
      }
    }
  }, AsyncIteratorPrototype), { addEventListener, removeAll } = listenersController();
  if (addEventListener(emitter, event, options[kFirstEventParam] ? eventHandler : function(...args) {
    return eventHandler(args);
  }), event !== "error" && typeof emitter.on === "function")
    addEventListener(emitter, "error", errorHandler);
  let closeEvents = options?.close;
  if (closeEvents?.length)
    for (let i = 0;i < closeEvents.length; i++)
      addEventListener(emitter, closeEvents[i], closeHandler);
  let abortListenerDisposable = signal ? addAbortListener(signal, abortListener) : null;
  return iterator;
  function abortListener() {
    errorHandler(@makeAbortError(@undefined, { cause: signal?.reason }));
  }
  function eventHandler(value) {
    if (unconsumedPromises.isEmpty()) {
      if (size++, !paused && size > highWatermark)
        paused = !0, emitter.pause();
      unconsumedEvents.push(value);
    } else
      unconsumedPromises.shift().resolve(createIterResult(value, !1));
  }
  function errorHandler(err) {
    if (unconsumedPromises.isEmpty())
      error = err;
    else
      unconsumedPromises.shift().reject(err);
    closeHandler();
  }
  function closeHandler() {
    abortListenerDisposable?.[Symbol.dispose](), removeAll(), finished = !0;
    let doneResult = createIterResult(@undefined, !0);
    while (!unconsumedPromises.isEmpty())
      unconsumedPromises.shift().resolve(doneResult);
    return @Promise.@resolve(doneResult);
  }
}
Object.defineProperty(on, "name", { value: "on" });
function listenersController() {
  let listeners2 = [];
  return {
    addEventListener(emitter, event, handler, flags) {
      eventTargetAgnosticAddListener(emitter, event, handler, flags), listeners2.push([emitter, event, handler, flags]);
    },
    removeAll() {
      while (listeners2.length > 0) {
        let [emitter, event, handler, flags] = listeners2.pop();
        eventTargetAgnosticRemoveListener(emitter, event, handler, flags);
      }
    }
  };
}
var getEventListenersForEventTarget = @lazy(51);
function getEventListeners(emitter, type) {
  if (@isCallable(emitter?.listeners))
    return emitter.listeners(type);
  return getEventListenersForEventTarget(emitter, type);
}
function setMaxListeners2(n = defaultMaxListeners, ...eventTargets) {
  if (validateNumber(n, "setMaxListeners", 0), eventTargets.length === 0)
    defaultMaxListeners = n;
  else
    for (let i = 0;i < eventTargets.length; i++) {
      let target = eventTargets[i];
      if (types.isEventTarget(target))
        target[kMaxEventTargetListeners] = n, target[kMaxEventTargetListenersWarned] = !1;
      else if (typeof target.setMaxListeners === "function")
        target.setMaxListeners(n);
      else
        throw @makeErrorWithCode(118, "eventTargets", ["EventEmitter", "EventTarget"], target);
    }
}
Object.defineProperty(setMaxListeners2, "name", { value: "setMaxListeners" });
var jsEventTargetGetEventListenersCount = @lazy(52);
function listenerCount2(emitter, type) {
  if (@isCallable(emitter.listenerCount))
    return emitter.listenerCount(type);
  let evt_count = jsEventTargetGetEventListenersCount(emitter, type);
  if (evt_count !== @undefined)
    return evt_count;
  return listenerCountSlow(emitter, type);
}
Object.defineProperty(listenerCount2, "name", { value: "listenerCount" });
function listenerCountSlow(emitter, type) {
  let events = emitter._events;
  if (events !== @undefined) {
    let evlistener = events[type];
    if (typeof evlistener === "function")
      return 1;
    else if (evlistener !== @undefined)
      return evlistener.length;
  }
  return 0;
}
function eventTargetAgnosticRemoveListener(emitter, name, listener, flags) {
  if (typeof emitter.removeListener === "function")
    emitter.removeListener(name, listener);
  else if (typeof emitter.removeEventListener === "function")
    emitter.removeEventListener(name, listener, flags);
  else
    throw @makeErrorWithCode(118, "emitter", "EventEmitter", emitter);
}
function eventTargetAgnosticAddListener(emitter, name, listener, flags) {
  if (typeof emitter.on === "function")
    if (flags?.once)
      emitter.once(name, listener);
    else
      emitter.on(name, listener);
  else if (typeof emitter.addEventListener === "function")
    emitter.addEventListener(name, listener, flags);
  else
    throw @makeErrorWithCode(118, "emitter", "EventEmitter", emitter);
}
function checkListener(listener) {
  validateFunction(listener, "listener");
}
function _getMaxListeners(emitter) {
  return emitter?._maxListeners ?? defaultMaxListeners;
}
var AsyncResource = null;
function getMaxListeners2(emitterOrTarget) {
  if (typeof emitterOrTarget?.getMaxListeners === "function")
    return _getMaxListeners(emitterOrTarget);
  else if (types.isEventTarget(emitterOrTarget))
    return emitterOrTarget[kMaxEventTargetListeners] ??= defaultMaxListeners, emitterOrTarget[kMaxEventTargetListeners];
  throw @makeErrorWithCode(118, "emitter", ["EventEmitter", "EventTarget"], emitterOrTarget);
}
Object.defineProperty(getMaxListeners2, "name", { value: "getMaxListeners" });
function addAbortListener(signal, listener) {
  if (signal === @undefined)
    throw @makeErrorWithCode(118, "signal", "AbortSignal", signal);
  if (validateAbortSignal(signal, "signal"), typeof listener !== "function")
    throw @makeErrorWithCode(118, "listener", "function", listener);
  let removeEventListener;
  if (signal.aborted)
    queueMicrotask(() => listener());
  else
    signal.addEventListener("abort", listener, { __proto__: null, once: !0 }), removeEventListener = () => {
      signal.removeEventListener("abort", listener);
    };
  return {
    __proto__: null,
    [Symbol.dispose]() {
      removeEventListener?.();
    }
  };
}

class EventEmitterAsyncResource extends EventEmitter {
  triggerAsyncId;
  asyncResource;
  constructor(options) {
    if (!AsyncResource)
      AsyncResource = (@getInternalField(@internalModuleRegistry, 86) || @createInternalModuleById(86)).AsyncResource;
    var { captureRejections = !1, triggerAsyncId, name = new.target.name, requireManualDestroy } = options || {};
    super({ captureRejections });
    this.triggerAsyncId = triggerAsyncId ?? 0, this.asyncResource = new AsyncResource(name, { triggerAsyncId, requireManualDestroy });
  }
  emit(...args) {
    this.asyncResource.runInAsyncScope(() => super.emit(...args));
  }
  emitDestroy() {
    this.asyncResource.emitDestroy();
  }
}
Object.defineProperties(EventEmitter, {
  captureRejections: {
    get() {
      return EventEmitterPrototype[kCapture];
    },
    set(value) {
      validateBoolean(value, "EventEmitter.captureRejections"), EventEmitterPrototype[kCapture] = value;
    },
    enumerable: !0
  },
  defaultMaxListeners: {
    enumerable: !0,
    get: () => {
      return defaultMaxListeners;
    },
    set: (arg) => {
      validateNumber(arg, "defaultMaxListeners", 0), defaultMaxListeners = arg;
    }
  },
  kMaxEventTargetListeners: {
    value: kMaxEventTargetListeners,
    enumerable: !1,
    configurable: !1,
    writable: !1
  },
  kMaxEventTargetListenersWarned: {
    value: kMaxEventTargetListenersWarned,
    enumerable: !1,
    configurable: !1,
    writable: !1
  }
});
Object.assign(EventEmitter, {
  once: once2,
  on,
  getEventListeners,
  getMaxListeners: getMaxListeners2,
  setMaxListeners: setMaxListeners2,
  EventEmitter,
  usingDomains: !1,
  captureRejectionSymbol,
  EventEmitterAsyncResource,
  errorMonitor: kErrorMonitor,
  addAbortListener,
  init: EventEmitter,
  listenerCount: listenerCount2
});
$ = EventEmitter;
return $})