558
559
constructor(socket: ISocket) {
561
>
this._socket = socket;
562
>
this._socketWriter = this._register(new ProtocolWriter(this._socket));
563
>
this._socketReader = this._register(new ProtocolReader(this._socket));
564
>
565
>
this._register(this._socketReader.onMessage((msg) => {
566
if (msg.type === ProtocolMessageType.Regular) {
567
this._onMessage.fire(msg.data);
568
}
570
>
571
>
this._register(this._socket.onClose(() => this._onDidDispose.fire()));
572
>
}
573
574
drain(): Promise<void> {