UNPKG

2.49 kBTypeScriptView Raw
1declare module "stream/promises" {
2 import { FinishedOptions, PipelineSource, PipelineTransform,
3 PipelineDestination, PipelinePromise, PipelineOptions } from "stream";
4
5 function finished(stream: NodeJS.ReadableStream | NodeJS.WritableStream | NodeJS.ReadWriteStream, options?: FinishedOptions): Promise<void>;
6
7 function pipeline<A extends PipelineSource<any>,
8 B extends PipelineDestination<A, any>>(
9 source: A,
10 destination: B,
11 options?: PipelineOptions
12 ): PipelinePromise<B>;
13 function pipeline<A extends PipelineSource<any>,
14 T1 extends PipelineTransform<A, any>,
15 B extends PipelineDestination<T1, any>>(
16 source: A,
17 transform1: T1,
18 destination: B,
19 options?: PipelineOptions
20 ): PipelinePromise<B>;
21 function pipeline<A extends PipelineSource<any>,
22 T1 extends PipelineTransform<A, any>,
23 T2 extends PipelineTransform<T1, any>,
24 B extends PipelineDestination<T2, any>>(
25 source: A,
26 transform1: T1,
27 transform2: T2,
28 destination: B,
29 options?: PipelineOptions
30 ): PipelinePromise<B>;
31 function pipeline<A extends PipelineSource<any>,
32 T1 extends PipelineTransform<A, any>,
33 T2 extends PipelineTransform<T1, any>,
34 T3 extends PipelineTransform<T2, any>,
35 B extends PipelineDestination<T3, any>>(
36 source: A,
37 transform1: T1,
38 transform2: T2,
39 transform3: T3,
40 destination: B,
41 options?: PipelineOptions
42 ): PipelinePromise<B>;
43 function pipeline<A extends PipelineSource<any>,
44 T1 extends PipelineTransform<A, any>,
45 T2 extends PipelineTransform<T1, any>,
46 T3 extends PipelineTransform<T2, any>,
47 T4 extends PipelineTransform<T3, any>,
48 B extends PipelineDestination<T4, any>>(
49 source: A,
50 transform1: T1,
51 transform2: T2,
52 transform3: T3,
53 transform4: T4,
54 destination: B,
55 options?: PipelineOptions
56 ): PipelinePromise<B>;
57
58 function pipeline(
59 streams: ReadonlyArray<NodeJS.ReadableStream | NodeJS.WritableStream | NodeJS.ReadWriteStream>,
60 options?: PipelineOptions
61 ): Promise<void>;
62 function pipeline(
63 stream1: NodeJS.ReadableStream,
64 stream2: NodeJS.ReadWriteStream | NodeJS.WritableStream,
65 ...streams: Array<NodeJS.ReadWriteStream | NodeJS.WritableStream | PipelineOptions>,
66 ): Promise<void>;
67}