method

stream.web.ReadableStream.pipeThrough

pipeThrough<T>(

transform: ReadableWritablePair<T, R>,

options?: StreamPipeOptions

): ReadableStream<T>;

Referenced types

interface ReadableWritablePair<R = any, W = any>

readable: ReadableStream<R>
writable: WritableStream<W>

interface StreamPipeOptions

preventAbort?: boolean
preventCancel?: boolean
preventClose?: boolean
signal?: AbortSignal

interface ReadableStream<R = any>

readonly locked: boolean
cancel(
reason?: any
): Promise<void>;
getReader(
options: { mode: 'byob' }
): ReadableStreamBYOBReader;
getReader(): ReadableStreamDefaultReader<R>;
getReader(
options?: ReadableStreamGetReaderOptions
): ReadableStreamReader<R>;
pipeThrough<T>(
transform: ReadableWritablePair<T, R>,
options?: StreamPipeOptions
): ReadableStream<T>;
pipeTo(
destination: WritableStream<R>,
options?: StreamPipeOptions
): Promise<void>;
tee(): [ReadableStream<R>, ReadableStream<R>];
values(
options?: ReadableStreamIteratorOptions
): ReadableStreamAsyncIterator<R>;