1 |
|
2 |
|
3 |
|
4 |
|
5 |
|
6 |
|
7 |
|
8 |
|
9 | import { Stream, Writable, Readable, Duplex } from 'stream';
|
10 | import * as duplexify from 'duplexify';
|
11 |
|
12 | declare class Pumpify extends Duplex implements duplexify.Duplexify {
|
13 | constructor(...streams: Stream[]);
|
14 | constructor(streams: Stream[]);
|
15 | setPipeline(...streams: Stream[]): void;
|
16 | setPipeline(streams: Stream[]): void;
|
17 |
|
18 | // Duplexify members
|
19 | setWritable(writable: Writable): void;
|
20 | setReadable(readable: Readable): void;
|
21 | }
|
22 |
|
23 | interface PumpifyFactoryOptions {
|
24 | autoDestroy: boolean;
|
25 | destroy: boolean;
|
26 | objectMode: boolean;
|
27 | highWaterMark: number;
|
28 | }
|
29 |
|
30 | declare namespace Pumpify {
|
31 | let obj: typeof Pumpify;
|
32 | function ctor(opts: PumpifyFactoryOptions): typeof Pumpify;
|
33 | }
|
34 |
|
35 | export = Pumpify;
|