{"version":3,"sources":["../../src/stream/identity_transform.ts"],"sourcesContent":["// SPDX-FileCopyrightText: 2025 LiveKit, Inc.\n//\n// SPDX-License-Identifier: Apache-2.0\nimport { TransformStream } from 'node:stream/web';\n\nexport class IdentityTransform<T> extends TransformStream<T, T> {\n  constructor() {\n    super(\n      {\n        transform: (chunk, controller) => controller.enqueue(chunk),\n      },\n      // By default the transfor stream will buffer only one chunk at a time.\n      // In order to follow the python agents channel.py, we set set the capaciy to be effectively infinite.\n      { highWaterMark: Number.MAX_SAFE_INTEGER },\n      { highWaterMark: Number.MAX_SAFE_INTEGER },\n    );\n  }\n}\n"],"mappings":";;;;;;;;;;;;;;;;;;AAAA;AAAA;AAAA;AAAA;AAAA;AAGA,iBAAgC;AAEzB,MAAM,0BAA6B,2BAAsB;AAAA,EAC9D,cAAc;AACZ;AAAA,MACE;AAAA,QACE,WAAW,CAAC,OAAO,eAAe,WAAW,QAAQ,KAAK;AAAA,MAC5D;AAAA;AAAA;AAAA,MAGA,EAAE,eAAe,OAAO,iBAAiB;AAAA,MACzC,EAAE,eAAe,OAAO,iBAAiB;AAAA,IAC3C;AAAA,EACF;AACF;","names":[]}