directly pass deserializeMessageWithInternalError to resolve

2023-07-13 20:59:04 +02:00 · 2023-07-13 20:59:04 +02:00 · 8ed0a50c58
parent c5bdd9c398
commit 8ed0a50c58
1 changed files with 4 additions and 8 deletions
--- a/packages/grpc-js/src/server-call.ts
+++ b/packages/grpc-js/src/server-call.ts
@ -615,19 +615,15 @@ export class Http2ServerCallStream<
        );

        if (Buffer.isBuffer(decompressedMessage)) {
-          call
-            .deserializeMessageWithInternalError(decompressedMessage)
-            .then(resolve)
-            .catch(reject);
+          resolve(
+            call.deserializeMessageWithInternalError(decompressedMessage)
+          );
          return;
        }

        decompressedMessage.then(
          decompressed =>
-            call
-              .deserializeMessageWithInternalError(decompressed)
-              .then(resolve)
-              .catch(reject),
+            resolve(call.deserializeMessageWithInternalError(decompressed)),
          (err: any) =>
            reject(
              err.code