diff --git a/packages/grpc-js-core/src/compression-filter.ts b/packages/grpc-js-core/src/compression-filter.ts index 6c874619..24d513dc 100644 --- a/packages/grpc-js-core/src/compression-filter.ts +++ b/packages/grpc-js-core/src/compression-filter.ts @@ -29,7 +29,7 @@ abstract class CompressionHandler { * @return Uncompressed message */ async readMessage(data: Buffer): Promise { - const compressed = data.readUInt8(1) === 1; + const compressed = data.readUInt8(0) === 1; let messageBuffer = data.slice(5); if (compressed) { messageBuffer = await this.decompressMessage(messageBuffer);