Method _emit

out/cli.cjs:81652–81684

(event, ...args)

        this.once("error", reject);
      this.once(event, resolve);
    });
  }
  async done() {
    __classPrivateFieldSet8(this, _EventStream_catchingPromiseCreated, true, "f");
    await __classPrivateFieldGet9(this, _EventStream_endPromise, "f");
  }
  _emit(event, ...args) {
    if (__classPrivateFieldGet9(this, _EventStream_ended, "f")) {
      return;
    }
    if (event === "end") {
      __classPrivateFieldSet8(this, _EventStream_ended, true, "f");
      __classPrivateFieldGet9(this, _EventStream_resolveEndPromise, "f").call(this);
    }
    const listeners = __classPrivateFieldGet9(this, _EventStream_listeners, "f")[event];
    if (listeners) {
      __classPrivateFieldGet9(this, _EventStream_listeners, "f")[event] = listeners.filter((l3) => !l3.once);
      listeners.forEach(({ listener }) => listener(...args));
    }
    if (event === "abort") {
      const error = args[0];
      if (!__classPrivateFieldGet9(this, _EventStream_catchingPromiseCreated, "f") && !listeners?.length) {
        Promise.reject(error);
      }
      __classPrivateFieldGet9(this, _EventStream_rejectConnectedPromise, "f").call(this, error);
      __classPrivateFieldGet9(this, _EventStream_rejectEndPromise, "f").call(this, error);
      this._emit("end");
      return;
    }
    if (event === "error") {
      const error = args[0];
      if (!__classPrivateFieldGet9(this, _EventStream_catchingPromiseCreated, "f") && !listeners?.length) {
        Promise.reject(error);
      }
      __classPrivateFieldGet9(this, _EventStream_rejectConnectedPromise, "f").call(this, error);
      __classPrivateFieldGet9(this, _EventStream_rejectEndPromise, "f").call(this, error);