Method _emit

out/cli.cjs:70379–70410

(event, ...args)

   * @returns a promise that resolves with the the final assistant Message's text response, concatenated
   * together if there are more than one text blocks.
   * Rejects if an error occurred or the stream ended prematurely without producing a Message.
   */
  async finalText() {
    await this.done();
    return __classPrivateFieldGet7(this, _MessageStream_instances, "m", _MessageStream_getFinalText).call(this);
  }
  _emit(event, ...args) {
    if (__classPrivateFieldGet7(this, _MessageStream_ended, "f"))
      return;
    if (event === "end") {
      __classPrivateFieldSet6(this, _MessageStream_ended, true, "f");
      __classPrivateFieldGet7(this, _MessageStream_resolveEndPromise, "f").call(this);
    }
    const listeners = __classPrivateFieldGet7(this, _MessageStream_listeners, "f")[event];
    if (listeners) {
      __classPrivateFieldGet7(this, _MessageStream_listeners, "f")[event] = listeners.filter((l3) => !l3.once);
      listeners.forEach(({ listener }) => listener(...args));
    }
    if (event === "abort") {
      const error = args[0];
      if (!__classPrivateFieldGet7(this, _MessageStream_catchingPromiseCreated, "f") && !listeners?.length) {
        Promise.reject(error);
      }
      __classPrivateFieldGet7(this, _MessageStream_rejectConnectedPromise, "f").call(this, error);
      __classPrivateFieldGet7(this, _MessageStream_rejectEndPromise, "f").call(this, error);
      this._emit("end");
      return;
    }
    if (event === "error") {
      const error = args[0];
      if (!__classPrivateFieldGet7(this, _MessageStream_catchingPromiseCreated, "f") && !listeners?.length) {
        Promise.reject(error);
      }
      __classPrivateFieldGet7(this, _MessageStream_rejectConnectedPromise, "f").call(this, error);
      __classPrivateFieldGet7(this, _MessageStream_rejectEndPromise, "f").call(this, error);