Function streamAdapter

  • A non-currying variant of withStreamAdapter. Takes a ReadableStream as an input and returns an async iterable that generates values from the stream.

    Returns

    An AsyncIterable of T generated from the ReadableStream.

    Example

    const stream = new ReadableStream({
    start(controller) {
    controller.enqueue('Hello');
    controller.close();
    },
    });
    const streamIterable = streamAdapter<string>(stream);

    (async () => {
    for await (const value of streamIterable) {
    console.log(value); // Logs "Hello"
    }
    })();

    Type Parameters

    • T

      The type of data contained in the ReadableStream.

    Parameters

    • stream: ReadableStream<T>

      The ReadableStream to adapt into an async iterable.

    Returns AsyncIterable<T>

Generated using TypeDoc