Skip to content

Commit

Permalink
Fixed test
Browse files Browse the repository at this point in the history
  • Loading branch information
ValentinZakharov committed Jun 24, 2024
1 parent b3305e9 commit c154a26
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -201,9 +201,9 @@ public void testNormalCalls() {
assertThat(cbp.getCallback(events.graphqlServerRequestMessage()).apply(null, null).getAction())
.isEqualTo(Flow.Action.Noop.INSTANCE);
ss.registerCallback(events.databaseConnection(), callback);
cbp.getCallback(events.databaseConnection()).accept(null, null);
cbp.getCallback(events.databaseConnection()).apply(null, null);
ss.registerCallback(events.databaseSqlQuery(), callback);
cbp.getCallback(events.databaseSqlQuery()).accept(null, null);
cbp.getCallback(events.databaseSqlQuery()).apply(null, null);
assertThat(callback.count).isEqualTo(Events.MAX_EVENTS);
}

Expand Down Expand Up @@ -257,9 +257,9 @@ public void testThrowableBlocking() {
assertThat(cbp.getCallback(events.graphqlServerRequestMessage()).apply(null, null).getAction())
.isEqualTo(Flow.Action.Noop.INSTANCE);
ss.registerCallback(events.databaseConnection(), throwback);
cbp.getCallback(events.databaseConnection()).accept(null, null);
cbp.getCallback(events.databaseConnection()).apply(null, null);
ss.registerCallback(events.databaseSqlQuery(), throwback);
cbp.getCallback(events.databaseSqlQuery()).accept(null, null);
cbp.getCallback(events.databaseSqlQuery()).apply(null, null);
assertThat(throwback.count).isEqualTo(Events.MAX_EVENTS);
}

Expand Down

0 comments on commit c154a26

Please sign in to comment.