UNPKG

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