Skip to content

Commit

Permalink
Update EventBrokerTest to increase timeout upper bound
Browse files Browse the repository at this point in the history
  • Loading branch information
breedloj authored Feb 13, 2025
1 parent f0e33fc commit 307e0c9
Showing 1 changed file with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ void testEventDelivery() {
Disposable subscription = eventBroker.subscribe(TestEvent.class, mockObserver);
eventBroker.post(testEvent);

verify(mockObserver, timeout(100)).onEvent(testEvent);
verify(mockObserver, timeout(1000)).onEvent(testEvent);

subscription.dispose();
}
Expand Down Expand Up @@ -66,9 +66,9 @@ void verifyEventOrderingMaintained() {
eventBroker.post(secondEvent);
eventBroker.post(thirdEvent);

verify(mockObserver, timeout(100)).onEvent(firstEvent);
verify(mockObserver, timeout(100)).onEvent(secondEvent);
verify(mockObserver, timeout(100)).onEvent(thirdEvent);
verify(mockObserver, timeout(1000)).onEvent(firstEvent);
verify(mockObserver, timeout(1000)).onEvent(secondEvent);
verify(mockObserver, timeout(1000)).onEvent(thirdEvent);

verifyNoMoreInteractions(mockObserver);

Expand Down Expand Up @@ -103,8 +103,8 @@ public int getValue() {
eventBroker.post(otherEvent);
eventBroker.post(secondEvent);

verify(testEventObserver, timeout(100).times(2)).onEvent(any());
verify(otherEventObserver, timeout(100).times(1)).onEvent(any());
verify(testEventObserver, timeout(1000).times(2)).onEvent(any());
verify(otherEventObserver, timeout(1000).times(1)).onEvent(any());

verifyNoMoreInteractions(testEventObserver);
verifyNoMoreInteractions(otherEventObserver);
Expand Down

0 comments on commit 307e0c9

Please sign in to comment.