@grpc/grpc-js
Advanced tools
Comparing version 1.2.4 to 1.2.5
@@ -257,7 +257,8 @@ "use strict"; | ||
serialized = this.methodDefinition.requestSerialize(message); | ||
this.call.sendMessageWithContext(context, serialized); | ||
} | ||
catch (e) { | ||
this.call.cancelWithStatus(constants_1.Status.INTERNAL, `Request message serialization failure: ${e.message}`); | ||
return; | ||
} | ||
this.call.sendMessageWithContext(context, serialized); | ||
} | ||
@@ -281,3 +282,2 @@ // eslint-disable-next-line @typescript-eslint/no-explicit-any | ||
deserialized = this.methodDefinition.responseDeserialize(message); | ||
(_a = interceptingListener === null || interceptingListener === void 0 ? void 0 : interceptingListener.onReceiveMessage) === null || _a === void 0 ? void 0 : _a.call(interceptingListener, deserialized); | ||
} | ||
@@ -291,3 +291,5 @@ catch (e) { | ||
this.call.cancelWithStatus(readError.code, readError.details); | ||
return; | ||
} | ||
(_a = interceptingListener === null || interceptingListener === void 0 ? void 0 : interceptingListener.onReceiveMessage) === null || _a === void 0 ? void 0 : _a.call(interceptingListener, deserialized); | ||
}, | ||
@@ -294,0 +296,0 @@ onReceiveStatus: (status) => { |
{ | ||
"name": "@grpc/grpc-js", | ||
"version": "1.2.4", | ||
"version": "1.2.5", | ||
"description": "gRPC Library for Node - pure JS implementation", | ||
@@ -5,0 +5,0 @@ "homepage": "https://grpc.io/", |
@@ -350,6 +350,7 @@ /* | ||
serialized = this.methodDefinition.requestSerialize(message); | ||
this.call.sendMessageWithContext(context, serialized); | ||
} catch (e) { | ||
this.call.cancelWithStatus(Status.INTERNAL, `Request message serialization failure: ${e.message}`); | ||
return; | ||
} | ||
this.call.sendMessageWithContext(context, serialized); | ||
} | ||
@@ -374,3 +375,2 @@ // eslint-disable-next-line @typescript-eslint/no-explicit-any | ||
deserialized = this.methodDefinition.responseDeserialize(message); | ||
interceptingListener?.onReceiveMessage?.(deserialized); | ||
} catch (e) { | ||
@@ -383,3 +383,5 @@ readError = { | ||
this.call.cancelWithStatus(readError.code, readError.details); | ||
return; | ||
} | ||
interceptingListener?.onReceiveMessage?.(deserialized); | ||
}, | ||
@@ -386,0 +388,0 @@ onReceiveStatus: (status) => { |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
937129
19486