{"version":3,"file":"consume-readable.cjs","names":["chunks: Uint8Array[]"],"sources":["../../src/utils/consume-readable.ts"],"sourcesContent":["/**\n * Consume a stream entirely, concatenating its content into a single\n * Uint8Array. Accepts either a Node Readable (data/end events) or a WHATWG\n * ReadableStream, so the same helper works under both the Node and browser\n * builds.\n */\nexport async function consumeReadable(\n  readable: NodeJS.ReadableStream | ReadableStream<Uint8Array>,\n): Promise<Uint8Array> {\n  if (typeof (readable as ReadableStream).getReader === \"function\") {\n    const reader = (readable as ReadableStream<Uint8Array>).getReader();\n    const chunks: Uint8Array[] = [];\n    let total = 0;\n    for (;;) {\n      const { value, done } = await reader.read();\n      if (done) break;\n      if (value) {\n        chunks.push(value);\n        total += value.byteLength;\n      }\n    }\n    const out = new Uint8Array(total);\n    let offset = 0;\n    for (const chunk of chunks) {\n      out.set(chunk, offset);\n      offset += chunk.byteLength;\n    }\n    return out;\n  }\n\n  return new Promise<Uint8Array>((resolve, reject) => {\n    const chunks: Uint8Array[] = [];\n    const node = readable as NodeJS.ReadableStream;\n    node.on(\"error\", (err) => reject(err));\n    node.on(\"data\", (chunk: Uint8Array) => chunks.push(chunk));\n    node.on(\"end\", () => {\n      let total = 0;\n      for (const c of chunks) total += c.byteLength;\n      const out = new Uint8Array(total);\n      let offset = 0;\n      for (const c of chunks) {\n        out.set(c, offset);\n        offset += c.byteLength;\n      }\n      resolve(out);\n    });\n  });\n}\n"],"mappings":";;;;;;;;AAMA,eAAsB,gBACpB,UACqB;AACrB,KAAI,OAAQ,SAA4B,cAAc,YAAY;EAChE,MAAM,SAAU,SAAwC,WAAW;EACnE,MAAMA,SAAuB,EAAE;EAC/B,IAAI,QAAQ;AACZ,WAAS;GACP,MAAM,EAAE,OAAO,SAAS,MAAM,OAAO,MAAM;AAC3C,OAAI,KAAM;AACV,OAAI,OAAO;AACT,WAAO,KAAK,MAAM;AAClB,aAAS,MAAM;;;EAGnB,MAAM,MAAM,IAAI,WAAW,MAAM;EACjC,IAAI,SAAS;AACb,OAAK,MAAM,SAAS,QAAQ;AAC1B,OAAI,IAAI,OAAO,OAAO;AACtB,aAAU,MAAM;;AAElB,SAAO;;AAGT,QAAO,IAAI,SAAqB,SAAS,WAAW;EAClD,MAAMA,SAAuB,EAAE;EAC/B,MAAM,OAAO;AACb,OAAK,GAAG,UAAU,QAAQ,OAAO,IAAI,CAAC;AACtC,OAAK,GAAG,SAAS,UAAsB,OAAO,KAAK,MAAM,CAAC;AAC1D,OAAK,GAAG,aAAa;GACnB,IAAI,QAAQ;AACZ,QAAK,MAAM,KAAK,OAAQ,UAAS,EAAE;GACnC,MAAM,MAAM,IAAI,WAAW,MAAM;GACjC,IAAI,SAAS;AACb,QAAK,MAAM,KAAK,QAAQ;AACtB,QAAI,IAAI,GAAG,OAAO;AAClB,cAAU,EAAE;;AAEd,WAAQ,IAAI;IACZ;GACF"}