Skip to content

Commit

Permalink
[Java] Fix assertion.
Browse files Browse the repository at this point in the history
  • Loading branch information
vyazelenko committed Feb 26, 2025
1 parent 85d5c69 commit bb0c2d9
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -520,7 +520,7 @@ void shouldHandleNonZeroTermOffsetCorrectly()
fillDataFrame(dataHeader, initialTermOffset); // initial data frame
receiveChannelEndpoint.onDataPacket(dataHeader, dataBuffer, alignedDataFrameLength, senderAddress, 0);

verify(mockHighestReceivedPosition).setRelease(initialTermOffset + alignedDataFrameLength);
verify(mockHighestReceivedPosition).proposeMaxRelease(initialTermOffset + alignedDataFrameLength);

final int readOutcome = TermReader.read(
termBuffers[ACTIVE_INDEX],
Expand Down

0 comments on commit bb0c2d9

Please sign in to comment.