UNPKG

1.34 kBTypeScriptView Raw
1import { ReadableBYOBStreamOptions, ReadableByteStreamOptions } from '../asynciterable/todomstream';
2export declare function toDOMStream<T>(source: Iterable<T>, strategy?: QueuingStrategy<T>): ReadableStream<T>;
3export declare function toDOMStream<T>(source: Iterable<T>, options: ReadableBYOBStreamOptions<Uint8Array>): ReadableStream<Uint8Array>;
4export declare function toDOMStream<T>(source: Iterable<T>, options: ReadableByteStreamOptions<Uint8Array>): ReadableStream<Uint8Array>;
5/**
6 * @ignore
7 */
8export declare function toDOMStreamProto<T>(this: Iterable<T>, strategy?: QueuingStrategy<T>): ReadableStream<T>;
9export declare function toDOMStreamProto<T>(this: Iterable<T>, options: ReadableBYOBStreamOptions<Uint8Array>): ReadableStream<Uint8Array>;
10export declare function toDOMStreamProto<T>(this: Iterable<T>, options: ReadableByteStreamOptions<Uint8Array>): ReadableStream<Uint8Array>;
11declare module '../iterable/iterablex' {
12 interface IterableX<T> {
13 toDOMStream: typeof toDOMStreamProto;
14 tee(): [ReadableStream<T>, ReadableStream<T>];
15 pipeTo(writable: WritableStream<T>, options?: PipeOptions): Promise<void>;
16 pipeThrough<R extends ReadableStream<any>>(duplex: {
17 writable: WritableStream<T>;
18 readable: R;
19 }, options?: PipeOptions): ReadableStream<T>;
20 }
21}