Method _fromReadableStream

out/cli.cjs:83060–83076

(readableStream, options)

      }
    };
  }
  static fromReadableStream(stream4) {
    const runner = new _AssistantStream();
    runner._run(() => runner._fromReadableStream(stream4));
    return runner;
  }
  async _fromReadableStream(readableStream, options) {
    const signal = options?.signal;
    if (signal) {
      if (signal.aborted)
        this.controller.abort();
      signal.addEventListener("abort", () => this.controller.abort());
    }
    this._connected();
    const stream4 = Stream2.fromReadableStream(readableStream, this.controller);
    for await (const event of stream4) {
      __classPrivateFieldGet12(this, _AssistantStream_instances, "m", _AssistantStream_addEvent).call(this, event);
    }
    if (stream4.controller.signal?.aborted) {
      throw new APIUserAbortError3();