declare module "node:stream/web" { import { TextDecoderCommon, TextDecoderOptions, TextEncoderCommon } from "node:util"; type CompressionFormat = "brotli" | "deflate" | "deflate-raw" | "gzip"; type ReadableStreamController = ReadableStreamDefaultController | ReadableByteStreamController; type ReadableStreamReader = ReadableStreamDefaultReader | ReadableStreamBYOBReader; type ReadableStreamReaderMode = "byob"; type ReadableStreamReadResult = ReadableStreamReadValueResult | ReadableStreamReadDoneResult; type ReadableStreamType = "bytes"; interface GenericTransformStream { readonly readable: ReadableStream; readonly writable: WritableStream; } interface QueuingStrategy { highWaterMark?: number; size?: QueuingStrategySize; } interface QueuingStrategyInit { highWaterMark: number; } interface QueuingStrategySize { (chunk: T): number; } interface ReadableStreamBYOBReaderReadOptions { min?: number; } interface ReadableStreamGenericReader { readonly closed: Promise; cancel(reason?: any): Promise; } interface ReadableStreamGetReaderOptions { mode?: ReadableStreamReaderMode; } interface ReadableStreamIteratorOptions { preventCancel?: boolean; } interface ReadableStreamReadDoneResult { done: true; value: T | undefined; } interface ReadableStreamReadValueResult { done: false; value: T; } interface ReadableWritablePair { readable: ReadableStream; writable: WritableStream; } interface StreamPipeOptions { preventAbort?: boolean; preventCancel?: boolean; preventClose?: boolean; signal?: AbortSignal; } interface Transformer { flush?: TransformerFlushCallback; readableType?: undefined; start?: TransformerStartCallback; transform?: TransformerTransformCallback; writableType?: undefined; } interface TransformerFlushCallback { (controller: TransformStreamDefaultController): void | PromiseLike; } interface TransformerStartCallback { (controller: TransformStreamDefaultController): any; } interface TransformerTransformCallback { (chunk: I, controller: TransformStreamDefaultController): void | PromiseLike; } interface UnderlyingByteSource { autoAllocateChunkSize?: number; cancel?: UnderlyingSourceCancelCallback; pull?: (controller: ReadableByteStreamController) => void | PromiseLike; start?: (controller: ReadableByteStreamController) => any; type: "bytes"; } interface UnderlyingDefaultSource { cancel?: UnderlyingSourceCancelCallback; pull?: (controller: ReadableStreamDefaultController) => void | PromiseLike; start?: (controller: ReadableStreamDefaultController) => any; type?: undefined; } interface UnderlyingSink { abort?: UnderlyingSinkAbortCallback; close?: UnderlyingSinkCloseCallback; start?: UnderlyingSinkStartCallback; type?: undefined; write?: UnderlyingSinkWriteCallback; } interface UnderlyingSinkAbortCallback { (reason?: any): void | PromiseLike; } interface UnderlyingSinkCloseCallback { (): void | PromiseLike; } interface UnderlyingSinkStartCallback { (controller: WritableStreamDefaultController): any; } interface UnderlyingSinkWriteCallback { (chunk: W, controller: WritableStreamDefaultController): void | PromiseLike; } interface UnderlyingSource { autoAllocateChunkSize?: number; cancel?: UnderlyingSourceCancelCallback; pull?: UnderlyingSourcePullCallback; start?: UnderlyingSourceStartCallback; type?: ReadableStreamType; } interface UnderlyingSourceCancelCallback { (reason?: any): void | PromiseLike; } interface UnderlyingSourcePullCallback { (controller: ReadableStreamController): void | PromiseLike; } interface UnderlyingSourceStartCallback { (controller: ReadableStreamController): any; } interface ByteLengthQueuingStrategy extends QueuingStrategy { readonly highWaterMark: number; readonly size: QueuingStrategySize; } var ByteLengthQueuingStrategy: { prototype: ByteLengthQueuingStrategy; new(init: QueuingStrategyInit): ByteLengthQueuingStrategy; }; interface CompressionStream extends GenericTransformStream { readonly readable: ReadableStream; readonly writable: WritableStream; } var CompressionStream: { prototype: CompressionStream; new(format: CompressionFormat): CompressionStream; }; interface CountQueuingStrategy extends QueuingStrategy { readonly highWaterMark: number; readonly size: QueuingStrategySize; } var CountQueuingStrategy: { prototype: CountQueuingStrategy; new(init: QueuingStrategyInit): CountQueuingStrategy; }; interface DecompressionStream extends GenericTransformStream { readonly readable: ReadableStream; readonly writable: WritableStream; } var DecompressionStream: { prototype: DecompressionStream; new(format: CompressionFormat): DecompressionStream; }; interface ReadableByteStreamController { readonly byobRequest: ReadableStreamBYOBRequest | null; readonly desiredSize: number | null; close(): void; enqueue(chunk: NodeJS.NonSharedArrayBufferView): void; error(e?: any): void; } var ReadableByteStreamController: { prototype: ReadableByteStreamController; new(): ReadableByteStreamController; }; interface ReadableStream { readonly locked: boolean; cancel(reason?: any): Promise; getReader(options: { mode: "byob" }): ReadableStreamBYOBReader; getReader(): ReadableStreamDefaultReader; getReader(options?: ReadableStreamGetReaderOptions): ReadableStreamReader; pipeThrough(transform: ReadableWritablePair, options?: StreamPipeOptions): ReadableStream; pipeTo(destination: WritableStream, options?: StreamPipeOptions): Promise; tee(): [ReadableStream, ReadableStream]; [Symbol.asyncIterator](options?: ReadableStreamIteratorOptions): ReadableStreamAsyncIterator; values(options?: ReadableStreamIteratorOptions): ReadableStreamAsyncIterator; } var ReadableStream: { prototype: ReadableStream; new( underlyingSource: UnderlyingByteSource, strategy?: { highWaterMark?: number }, ): ReadableStream; new(underlyingSource: UnderlyingDefaultSource, strategy?: QueuingStrategy): ReadableStream; new(underlyingSource?: UnderlyingSource, strategy?: QueuingStrategy): ReadableStream; from(iterable: Iterable | AsyncIterable): ReadableStream; }; interface ReadableStreamAsyncIterator extends NodeJS.AsyncIterator { [Symbol.asyncIterator](): ReadableStreamAsyncIterator; } interface ReadableStreamBYOBReader extends ReadableStreamGenericReader { read( view: T, options?: ReadableStreamBYOBReaderReadOptions, ): Promise>; releaseLock(): void; } var ReadableStreamBYOBReader: { prototype: ReadableStreamBYOBReader; new(stream: ReadableStream): ReadableStreamBYOBReader; }; interface ReadableStreamBYOBRequest { readonly view: NodeJS.NonSharedArrayBufferView | null; respond(bytesWritten: number): void; respondWithNewView(view: NodeJS.NonSharedArrayBufferView): void; } var ReadableStreamBYOBRequest: { prototype: ReadableStreamBYOBRequest; new(): ReadableStreamBYOBRequest; }; interface ReadableStreamDefaultController { readonly desiredSize: number | null; close(): void; enqueue(chunk: R): void; error(e?: any): void; } var ReadableStreamDefaultController: { prototype: ReadableStreamDefaultController; new(): ReadableStreamDefaultController; }; interface ReadableStreamDefaultReader extends ReadableStreamGenericReader { read(): Promise>; releaseLock(): void; } var ReadableStreamDefaultReader: { prototype: ReadableStreamDefaultReader; new(stream: ReadableStream): ReadableStreamDefaultReader; }; interface TextDecoderStream extends GenericTransformStream, TextDecoderCommon { readonly readable: ReadableStream; readonly writable: WritableStream; } var TextDecoderStream: { prototype: TextDecoderStream; new(label?: string, options?: TextDecoderOptions): TextDecoderStream; }; interface TextEncoderStream extends GenericTransformStream, TextEncoderCommon { readonly readable: ReadableStream; readonly writable: WritableStream; } var TextEncoderStream: { prototype: TextEncoderStream; new(): TextEncoderStream; }; interface TransformStream { readonly readable: ReadableStream; readonly writable: WritableStream; } var TransformStream: { prototype: TransformStream; new( transformer?: Transformer, writableStrategy?: QueuingStrategy, readableStrategy?: QueuingStrategy, ): TransformStream; }; interface TransformStreamDefaultController { readonly desiredSize: number | null; enqueue(chunk: O): void; error(reason?: any): void; terminate(): void; } var TransformStreamDefaultController: { prototype: TransformStreamDefaultController; new(): TransformStreamDefaultController; }; interface WritableStream { readonly locked: boolean; abort(reason?: any): Promise; close(): Promise; getWriter(): WritableStreamDefaultWriter; } var WritableStream: { prototype: WritableStream; new(underlyingSink?: UnderlyingSink, strategy?: QueuingStrategy): WritableStream; }; interface WritableStreamDefaultController { readonly signal: AbortSignal; error(e?: any): void; } var WritableStreamDefaultController: { prototype: WritableStreamDefaultController; new(): WritableStreamDefaultController; }; interface WritableStreamDefaultWriter { readonly closed: Promise; readonly desiredSize: number | null; readonly ready: Promise; abort(reason?: any): Promise; close(): Promise; releaseLock(): void; write(chunk: W): Promise; } var WritableStreamDefaultWriter: { prototype: WritableStreamDefaultWriter; new(stream: WritableStream): WritableStreamDefaultWriter; }; } declare module "stream/web" { export * from "node:stream/web"; }