diff options
-rw-r--r-- | src/node/src/client.js | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/node/src/client.js b/src/node/src/client.js index 9cc5a62bdb..2459e28321 100644 --- a/src/node/src/client.js +++ b/src/node/src/client.js @@ -149,6 +149,9 @@ function _readsDone(status) { if (!status) { status = {code: grpc.status.OK, details: 'OK'}; } + if (status.code !== grpc.status.OK) { + this.call.cancelWithStatus(status.code, status.details); + } this.finished = true; this.read_status = status; this._emitStatusIfDone(); |