diff --git a/src/rpc/service.js b/src/rpc/service.js index 880bd04f0..d94053683 100644 --- a/src/rpc/service.js +++ b/src/rpc/service.js @@ -118,7 +118,7 @@ Service.prototype.rpcCall = function rpcCall(method, requestCtor, responseCtor, response = responseCtor[self.responseDelimited ? "decodeDelimited" : "decode"](response); } catch (err) { self.emit("error", err, method); - return callback("error", err); + return callback(err); } }