/** * Creates a curried function that takes a ReadableStream as an input and returns an async iterable that generates values from the stream. * * @group Adapters * @template T - The type of data contained in the ReadableStream. * @returns {(input: ReadableStream) => AsyncIterable} A function that takes a ReadableStream as input and returns an AsyncIterable of T. * * @example * ```ts * const stream = new ReadableStream({ * start(controller) { * controller.enqueue('Hello'); * controller.close(); * }, * }); * const streamIterable = withStreamAdapter()(stream); * * (async () => { * for await (const value of streamIterable) { * console.log(value); // Logs "Hello" * } * })(); * ``` */ export declare const withStreamAdapter: () => (input: ReadableStream) => import("../../types").ExtendedAsyncIterable; /** * A non-currying variant of {@link withStreamAdapter}. Takes a ReadableStream as an input and returns an async iterable that generates values from the stream. * * @group Adapters * @template T - The type of data contained in the ReadableStream. * @param {ReadableStream} stream - The ReadableStream to adapt into an async iterable. * @returns {AsyncIterable} An AsyncIterable of T generated from the ReadableStream. * * @example * ```ts * const stream = new ReadableStream({ * start(controller) { * controller.enqueue('Hello'); * controller.close(); * }, * }); * const streamIterable = streamAdapter(stream); * * (async () => { * for await (const value of streamIterable) { * console.log(value); // Logs "Hello" * } * })(); * ``` */ export declare const streamAdapter: (stream: ReadableStream) => import("../../types").ExtendedAsyncIterable;