Method fromSSEResponse

out/cli.cjs:69073–69122

(response, controller)

};

// node_modules/@anthropic-ai/sdk/streaming.mjs
var Stream = class _Stream {
  constructor(iterator2, controller) {
    this.iterator = iterator2;
    this.controller = controller;
  }
  static fromSSEResponse(response, controller) {
    let consumed = false;
    async function* iterator2() {
      if (consumed) {
        throw new Error("Cannot iterate over a consumed stream, use `.tee()` to split the stream.");
      }
      consumed = true;
      let done = false;
      try {
        for await (const sse of _iterSSEMessages(response, controller)) {
          if (sse.event === "completion") {
            try {
              yield JSON.parse(sse.data);
            } catch (e3) {
              console.error(`Could not parse message into JSON:`, sse.data);
              console.error(`From chunk:`, sse.raw);
              throw e3;
            }
          }
          if (sse.event === "message_start" || sse.event === "message_delta" || sse.event === "message_stop" || sse.event === "content_block_start" || sse.event === "content_block_delta" || sse.event === "content_block_stop") {
            try {
              yield JSON.parse(sse.data);
            } catch (e3) {
              console.error(`Could not parse message into JSON:`, sse.data);
              console.error(`From chunk:`, sse.raw);
              throw e3;
            }
          }
          if (sse.event === "ping") {
            continue;
          }
          if (sse.event === "error") {
            const errText = sse.data;
            const errJSON = safeJSON(errText);
            const errMessage = errJSON ? void 0 : errText;
            throw APIError.generate(void 0, errJSON, errMessage, createResponseHeaders(response.headers));
          }
        }
        done = true;
      } catch (e3) {
        if (e3 instanceof Error && e3.name === "AbortError")
          return;
        throw e3;
      } finally {
        if (!done)
          controller.abort();
      }