diff --git a/src/client.js b/src/client.js index 073b907..a389b52 100644 --- a/src/client.js +++ b/src/client.js @@ -103,6 +103,9 @@ class RPCClient extends EventEmitter { resolve(this); }); this.transport.once('close', () => { + this._expecting.forEach((e) => { + e.reject(new Error('connection closed')); + }); this.emit('disconnected'); reject(); });