UNPKG

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