mirror of https://github.com/grpc/grpc-web.git
refactor hanndle error
This commit is contained in:
parent
630ab16f4a
commit
1e450e683c
|
@ -270,7 +270,7 @@ class GrpcWebClientReadableStream {
|
||||||
if (Number(grpcStatusCode) != StatusCode.OK) {
|
if (Number(grpcStatusCode) != StatusCode.OK) {
|
||||||
self.handleError_({
|
self.handleError_({
|
||||||
code: Number(grpcStatusCode),
|
code: Number(grpcStatusCode),
|
||||||
message: decodeURIComponent(grpcStatusMessage || ""),
|
message: grpcStatusMessage,
|
||||||
metadata: responseHeaders
|
metadata: responseHeaders
|
||||||
});
|
});
|
||||||
errorEmitted = true;
|
errorEmitted = true;
|
||||||
|
@ -379,7 +379,11 @@ class GrpcWebClientReadableStream {
|
||||||
*/
|
*/
|
||||||
handleError_(error) {
|
handleError_(error) {
|
||||||
if (error.code != StatusCode.OK) {
|
if (error.code != StatusCode.OK) {
|
||||||
this.sendErrorCallbacks_(error);
|
this.sendErrorCallbacks_({
|
||||||
|
code: error.code,
|
||||||
|
message: decodeURIComponent(error.message || ''),
|
||||||
|
metadata: error.metadata
|
||||||
|
});
|
||||||
}
|
}
|
||||||
this.sendStatusCallbacks_(/** @type {!Status} */ ({
|
this.sendStatusCallbacks_(/** @type {!Status} */ ({
|
||||||
code: error.code,
|
code: error.code,
|
||||||
|
|
Loading…
Reference in New Issue