1 | import { Transform } from 'stream';
|
2 | import Debug from './debug';
|
3 | import Message from './message';
|
4 | import { ConnectionError } from './errors';
|
5 |
|
6 |
|
7 |
|
8 |
|
9 | declare class IncomingMessageStream extends Transform {
|
10 | debug: Debug;
|
11 | bl: any;
|
12 | currentMessage: Message | undefined;
|
13 | constructor(debug: Debug);
|
14 | pause(): this;
|
15 | resume(): this;
|
16 | processBufferedData(callback: (err?: ConnectionError) => void): void;
|
17 | _transform(chunk: Buffer, _encoding: string, callback: () => void): void;
|
18 | }
|
19 | export default IncomingMessageStream;
|