Rocky_Mountain_Vending/.pnpm-store/v10/files/7e/14a12b3a227ebcaced89c6417d31b945c302c7fd94733783e129d233ceecbea76f216cb7777d5f64145a9ce2a077a21f70c45d0c098f110cd5c779b14fc321

{"version":3,"sources":["../../../src/client/dev/debug-channel.ts"],"sourcesContent":["import { NEXT_REQUEST_ID_HEADER } from '../components/app-router-headers'\nimport { InvariantError } from '../../shared/lib/invariant-error'\n\nexport interface DebugChannelReadableWriterPair {\n  readonly readable: ReadableStream<Uint8Array>\n  readonly writer: WritableStreamDefaultWriter<Uint8Array>\n}\n\nconst pairs = new Map<string, DebugChannelReadableWriterPair>()\n\nexport function getOrCreateDebugChannelReadableWriterPair(\n  requestId: string\n): DebugChannelReadableWriterPair {\n  let pair = pairs.get(requestId)\n\n  if (!pair) {\n    const { readable, writable } = new TransformStream<Uint8Array, Uint8Array>()\n    pair = { readable, writer: writable.getWriter() }\n    pairs.set(requestId, pair)\n    pair.writer.closed.finally(() => pairs.delete(requestId))\n  }\n\n  return pair\n}\n\nexport function createDebugChannel(\n  requestHeaders: Record<string, string> | undefined\n): {\n  writable?: WritableStream\n  readable?: ReadableStream\n} {\n  let requestId: string | undefined\n\n  if (requestHeaders) {\n    requestId = requestHeaders[NEXT_REQUEST_ID_HEADER] ?? undefined\n\n    if (!requestId) {\n      throw new InvariantError(\n        `Expected a ${JSON.stringify(NEXT_REQUEST_ID_HEADER)} request header.`\n      )\n    }\n  } else {\n    requestId = self.__next_r\n\n    if (!requestId) {\n      throw new InvariantError(\n        `Expected a request ID to be defined for the document via self.__next_r.`\n      )\n    }\n  }\n\n  const { readable } = getOrCreateDebugChannelReadableWriterPair(requestId)\n\n  return { readable }\n}\n"],"names":["NEXT_REQUEST_ID_HEADER","InvariantError","pairs","Map","getOrCreateDebugChannelReadableWriterPair","requestId","pair","get","readable","writable","TransformStream","writer","getWriter","set","closed","finally","delete","createDebugChannel","requestHeaders","undefined","JSON","stringify","self","__next_r"],"mappings":"AAAA,SAASA,sBAAsB,QAAQ,mCAAkC;AACzE,SAASC,cAAc,QAAQ,mCAAkC;AAOjE,MAAMC,QAAQ,IAAIC;AAElB,OAAO,SAASC,0CACdC,SAAiB;IAEjB,IAAIC,OAAOJ,MAAMK,GAAG,CAACF;IAErB,IAAI,CAACC,MAAM;QACT,MAAM,EAAEE,QAAQ,EAAEC,QAAQ,EAAE,GAAG,IAAIC;QACnCJ,OAAO;YAAEE;YAAUG,QAAQF,SAASG,SAAS;QAAG;QAChDV,MAAMW,GAAG,CAACR,WAAWC;QACrBA,KAAKK,MAAM,CAACG,MAAM,CAACC,OAAO,CAAC,IAAMb,MAAMc,MAAM,CAACX;IAChD;IAEA,OAAOC;AACT;AAEA,OAAO,SAASW,mBACdC,cAAkD;IAKlD,IAAIb;IAEJ,IAAIa,gBAAgB;QAClBb,YAAYa,cAAc,CAAClB,uBAAuB,IAAImB;QAEtD,IAAI,CAACd,WAAW;YACd,MAAM,qBAEL,CAFK,IAAIJ,eACR,CAAC,WAAW,EAAEmB,KAAKC,SAAS,CAACrB,wBAAwB,gBAAgB,CAAC,GADlE,qBAAA;uBAAA;4BAAA;8BAAA;YAEN;QACF;IACF,OAAO;QACLK,YAAYiB,KAAKC,QAAQ;QAEzB,IAAI,CAAClB,WAAW;YACd,MAAM,qBAEL,CAFK,IAAIJ,eACR,CAAC,uEAAuE,CAAC,GADrE,qBAAA;uBAAA;4BAAA;8BAAA;YAEN;QACF;IACF;IAEA,MAAM,EAAEO,QAAQ,EAAE,GAAGJ,0CAA0CC;IAE/D,OAAO;QAAEG;IAAS;AACpB","ignoreList":[0]}