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