Skip to content

Commit

Permalink
Add counter check
Browse files Browse the repository at this point in the history
  • Loading branch information
marc-adaptive committed Sep 3, 2024
1 parent faa1514 commit 0862cec
Showing 1 changed file with 5 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -733,6 +733,11 @@ static void assertEngineSubscriptionCaughtUpToLibraryPublication(
countersReader.forEach((counterId, typeId, keyBuffer, label) ->
subPosMatcher.tryMatch(counterId, typeId, keyBuffer));

if (!subPosMatcher.hasCounterId())
{
throw new IllegalStateException("did not match counter: " + subPosMatcher);
}

assertEventuallyTrue(
() ->
{
Expand Down

0 comments on commit 0862cec

Please sign in to comment.