Emit status event on empty stream response

The-Peso-G · Jan 8, 2019 · bca6308 · bca6308
1 parent f181d1e
commit bca6308
Showing 1 changed file with 12 additions and 2 deletions.
diff --git a/javascript/net/grpc/web/grpcwebclientreadablestream.js b/javascript/net/grpc/web/grpcwebclientreadablestream.js
@@ -119,6 +119,16 @@ const GrpcWebClientReadableStream = function(genericTransportInterface) {
     if (!contentType) return;
     contentType = contentType.toLowerCase();
 
+    var grpcStatusCode = self.xhr_.getStreamingResponseHeader(GRPC_STATUS);
+    var grpcStatusMessage = self.xhr_.getStreamingResponseHeader(GRPC_STATUS_MESSAGE);
+    if (grpcStatusCode && self.onStatusCallback_) {
+      self.onStatusCallback_({
+        code: Number(grpcStatusCode),
+        details: grpcStatusMessage,
+        metadata: undefined,
+      });
+    }
+
     if (googString.startsWith(contentType, 'application/grpc-web-text')) {
       var responseText = self.xhr_.getResponseText();
       var newPos = responseText.length - responseText.length % 4;
@@ -155,8 +165,8 @@ const GrpcWebClientReadableStream = function(genericTransportInterface) {
               messages[i][FrameType.TRAILER][pos]);
           }
           var trailers = self.parseHttp1Headers_(trailerString);
-          var grpcStatusCode = StatusCode.OK;
-          var grpcStatusMessage = "";
+          grpcStatusCode = StatusCode.OK;
+          grpcStatusMessage = "";
           if (GRPC_STATUS in trailers) {
             grpcStatusCode = trailers[GRPC_STATUS];
           }