{"version":3,"sources":["../../../src/internals/helpers/stream.ts"],"names":["transformAsyncIterable","generator","transformer","next","done","value","isAsyncIterable","Boolean","Symbol","asyncIterator"],"mappings":";;;;AAKA,gBAAuBA,sBAAAA,CACrBC,WACAC,WAAAA,EAA2B;AAE3B,EAAA,IAAIC,IAAAA;AACJ,EAAA,OAAO,EAAEA,IAAAA,GAAO,MAAMF,SAAAA,CAAUE,IAAAA,IAAQC,IAAAA,EAAM;AAC5C,IAAA,MAAMF,WAAAA,CAAYC,KAAKE,KAAK,CAAA;AAC9B,EAAA;AACA,EAAA,OAAOF,IAAAA,CAAKE,KAAAA;AACd;AATuBL,MAAAA,CAAAA,sBAAAA,EAAAA,wBAAAA,CAAAA;AAWhB,SAASM,gBAAmBD,KAAAA,EAAU;AAC3C,EAAA,OAAOE,OAAAA,CAAQF,KAAAA,IAASG,MAAAA,CAAOC,aAAAA,IAAiBJ,KAAAA,CAAAA;AAClD;AAFgBC,MAAAA,CAAAA,eAAAA,EAAAA,iBAAAA,CAAAA","file":"stream.cjs","sourcesContent":["/**\n * Copyright 2025 © BeeAI a Series of LF Projects, LLC\n * SPDX-License-Identifier: Apache-2.0\n */\n\nexport async function* transformAsyncIterable<A, B, A2>(\n  generator: AsyncGenerator<A, B> | AsyncIterableIterator<A>,\n  transformer: (old: A) => A2,\n): AsyncGenerator<A2, B> {\n  let next: IteratorResult<A, B>;\n  while (!(next = await generator.next()).done) {\n    yield transformer(next.value);\n  }\n  return next.value;\n}\n\nexport function isAsyncIterable<T>(value: any): value is AsyncIterable<T> {\n  return Boolean(value && Symbol.asyncIterator in value);\n}\n"]}