Function collectStream

src/node/utils/gatewayStreamNormalization.test.ts:181–200

(chunks: unknown[])

describe("normalizeGatewayStreamUsage", () => {
  async function collectStream(chunks: unknown[]): Promise<unknown[]> {
    const stream = new ReadableStream({
      start(controller) {
        for (const chunk of chunks) {
          controller.enqueue(chunk);
        }
        controller.close();
      },
    });

    const result: unknown[] = [];
    const transformed: ReadableStream<unknown> = stream.pipeThrough(normalizeGatewayStreamUsage());
    const reader = transformed.getReader();
    for (;;) {
      const chunk = await reader.read();
      if (chunk.done) break;
      result.push(chunk.value);
    }
    return result;
  }

  it("passes non-finish events through unchanged", async () => {
    const chunks = [