Skip to content

Commit

Permalink
fix: applied changes to test based on comments
Browse files Browse the repository at this point in the history
  • Loading branch information
MarioJGMsoft committed Jan 17, 2025
1 parent 19c0ac2 commit 7e02b32
Showing 1 changed file with 7 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@ import {
ensureContentsDeserialized,
type IBatch,
type InboundMessageResult,
OpCompressor,
OpDecompressor,
OpGroupingManager,
OpSplitter,
Expand Down Expand Up @@ -136,7 +137,12 @@ describe("RemoteMessageProcessor", () => {
let leadingChunkCount = 0;
const outboundMessages: IBatchMessage[] = [];
if (option.compressionAndChunking.compression) {
batch = compressMultipleMessageBatch(batch);
if (batch.messages.length === 1) {
const compressor = new OpCompressor(mockLogger);
batch = compressor.compressBatch(batch);
} else {
batch = compressMultipleMessageBatch(batch);
}

if (option.compressionAndChunking.chunking) {
const splitter = new OpSplitter(
Expand Down

0 comments on commit 7e02b32

Please sign in to comment.