UNPKG

495 BTypeScriptView Raw
1import { Duplex } from 'stream';
2import Debug from './debug';
3import Message from './message';
4declare class OutgoingMessageStream extends Duplex {
5 packetSize: number;
6 debug: Debug;
7 bl: any;
8 currentMessage: Message | undefined;
9 constructor(debug: Debug, { packetSize }: {
10 packetSize: number;
11 });
12 _write(message: Message, _encoding: string, callback: (err?: Error | null) => void): void;
13 _read(_size: number): void;
14}
15export default OutgoingMessageStream;