1 |
|
2 | import { Readable, ReadableOptions, Writable, WritableOptions } from 'stream';
|
3 | export declare class NullStream extends Writable {
|
4 | _write(chunk: any, encoding: string, callback: () => void): void;
|
5 | }
|
6 | export interface ReadableStreamBufferOptions extends ReadableOptions {
|
7 | chunkSize?: number;
|
8 | allocSize?: number;
|
9 | growSize?: number;
|
10 | }
|
11 | export declare class ReadableStreamBuffer extends Readable {
|
12 | protected buffer: Buffer;
|
13 | protected _size: number;
|
14 | protected _stopped: boolean;
|
15 | protected chunkSize: number;
|
16 | protected growSize: number;
|
17 | constructor(opts?: ReadableStreamBufferOptions);
|
18 | get size(): number;
|
19 | get stopped(): boolean;
|
20 | _read(): void;
|
21 | feed(data: Buffer | string, encoding?: string): void;
|
22 | stop(): void;
|
23 | protected _send(): void;
|
24 | }
|
25 | export interface WritableStreamBufferOptions extends WritableOptions {
|
26 | allocSize?: number;
|
27 | growSize?: number;
|
28 | }
|
29 | export declare class WritableStreamBuffer extends Writable {
|
30 | protected buffer: Buffer;
|
31 | protected _size: number;
|
32 | protected growSize: number;
|
33 | constructor(opts?: WritableStreamBufferOptions);
|
34 | get size(): number;
|
35 | _write(chunk: any, encoding: string, callback: () => void): void;
|
36 | consume(bytes?: number): Buffer;
|
37 | }
|
38 | export declare function growBufferForAppendedData(buf: Buffer, actualsize: number, appendsize: number): Buffer;
|