( source: AsyncIterable<Uint8Array>, )
| 17 | * @returns An async generator yielding decoded text chunks. |
| 18 | */ |
| 19 | export async function* decodeAsyncIterable( |
| 20 | source: AsyncIterable<Uint8Array>, |
| 21 | ): AsyncGenerator<string> { |
| 22 | const decoder = new TextDecoder(); |
| 23 | for await (const chunk of source) { |
| 24 | yield decoder.decode(chunk, { stream: true }); |
| 25 | } |
| 26 | const final = decoder.decode(); |
| 27 | if (final) yield final; |
| 28 | } |
no outgoing calls
no test coverage detected