Fix bug in previous commit

This commit is contained in:
Guangcong Luo 2018-10-20 17:55:54 -05:00
parent 4e9ad4e373
commit c934c04bbc

View File

@ -28,12 +28,12 @@ class SubprocessStream extends Streams.ObjectReadWriteStream {
this.process.send(`${taskId}\nNEW`);
}
_write(/** @type {string} */ message) {
if (!process.connected) return;
if (!this.process.connected) return;
this.process.send(`${this.taskId}\nWRITE\n${message}`);
// responses are handled in ProcessWrapper
}
_destroy() {
if (!process.connected) return;
if (!this.process.connected) return;
this.process.send(`${this.taskId}\nDESTROY`);
}
}