Class IPCMessageWriter

jsonrpc/src/messageWriter.ts:108–158

}

export class IPCMessageWriter extends AbstractMessageWriter implements MessageWriter {

	private process: NodeJS.Process | ChildProcess;
	private queue: Message[];
	private sending: boolean;
	private errorCount: number;

	public constructor(process: NodeJS.Process | ChildProcess) {
		super();
		this.process = process;
		this.errorCount = 0;
		this.queue = [];
		this.sending = false;
		let eventEmitter: NodeJS.EventEmitter = this.process;
		eventEmitter.on('error', (error: any) => this.fireError(error));
		eventEmitter.on('close', () => this.fireClose);
	}

	public write(msg: Message): void {
		if (!this.sending && this.queue.length === 0) {
			// See https://github.com/nodejs/node/issues/7657
			this.doWriteMessage(msg);
		} else {
			this.queue.push(msg);
		}
	}

	public doWriteMessage(msg: Message): void {
		try {
			if (this.process.send) {
				this.sending = true;
				(this.process.send as Function)(msg, undefined, undefined, (error: any) => {
					this.sending = false;
					if (error) {
						this.errorCount++;
						this.fireError(error, msg, this.errorCount);
					} else {
						this.errorCount = 0;
					}
					if (this.queue.length > 0) {
						this.doWriteMessage(this.queue.shift()!);
					}
				});
			}
		} catch (error) {
			this.errorCount++;
			this.fireError(error, msg, this.errorCount);
		}

	}
 }

 export class SocketMessageWriter extends AbstractMessageWriter implements MessageWriter {