UNPKG

634 BTypeScriptView Raw
1import { Transform } from 'stream';
2import Debug from './debug';
3import Message from './message';
4import { ConnectionError } from './errors';
5/**
6 IncomingMessageStream
7 Transform received TDS data into individual IncomingMessage streams.
8*/
9declare 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}
19export default IncomingMessageStream;