1 |
|
2 |
|
3 | import { Readable, Transform } from 'node:stream';
|
4 | import { DeferredPromise } from '@naturalcycles/js-lib';
|
5 | type AnyStream = NodeJS.ReadableStream | NodeJS.WritableStream | NodeJS.ReadWriteStream;
|
6 | export interface PipelineOptions {
|
7 | |
8 |
|
9 |
|
10 |
|
11 | allowClose?: boolean;
|
12 | }
|
13 |
|
14 |
|
15 |
|
16 |
|
17 |
|
18 |
|
19 | export declare function _pipeline(streams: AnyStream[], opt?: PipelineOptions): Promise<void>;
|
20 |
|
21 |
|
22 |
|
23 |
|
24 | export declare function _pipelineToArray<T>(streams: AnyStream[], opt?: PipelineOptions): Promise<T[]>;
|
25 | export declare class AbortableTransform extends Transform {
|
26 | sourceReadable?: Readable;
|
27 | streamDone?: DeferredPromise;
|
28 | }
|
29 | export {};
|