Skip to content

Commit 69428b0

Browse files
committed
simplify removal of compression prefix bytes
1 parent 9cdd36f commit 69428b0

File tree

1 file changed

+4
-9
lines changed

1 file changed

+4
-9
lines changed

packages/grpc-js/src/server-call.ts

Lines changed: 4 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -454,8 +454,7 @@ export class Http2ServerCallStream<
454454
});
455455
resolve();
456456
} else {
457-
const joined = Buffer.concat([message.slice(0, 5), output]);
458-
resolve(joined);
457+
resolve(output);
459458
}
460459
});
461460
});
@@ -471,15 +470,14 @@ export class Http2ServerCallStream<
471470
});
472471
resolve();
473472
} else {
474-
const joined = Buffer.concat([message.slice(0, 5), output]);
475-
resolve(joined);
473+
resolve(output);
476474
}
477475
});
478476
});
479477
}
480478

481479
case 'identity': {
482-
return Promise.resolve(message);
480+
return Promise.resolve(message.slice(5));
483481
}
484482

485483
default: {
@@ -603,10 +601,7 @@ export class Http2ServerCallStream<
603601
}
604602

605603
deserializeMessage(bytes: Buffer) {
606-
// TODO(cjihrig): Call compression aware deserializeMessage().
607-
const receivedMessage = bytes.slice(5);
608-
609-
return this.handler.deserialize(receivedMessage);
604+
return this.handler.deserialize(bytes);
610605
}
611606

612607
async sendUnaryMessage(

0 commit comments

Comments
 (0)