@@ -601,13 +601,13 @@ void matchingStaleEventsMustRunImmediately() {
601
601
OpenFeatureAPI api = OpenFeatureAPI .getInstance ();
602
602
603
603
// provider which is already stale
604
- TestEventsProvider provider = TestEventsProvider . newInitializedTestEventsProvider ( );
604
+ TestEventsProvider provider = new TestEventsProvider ( INIT_DELAY );
605
605
Client client = api .getClient (name );
606
606
api .setProviderAndWait (name , provider );
607
607
provider .emitProviderStale (ProviderEventDetails .builder ().build ());
608
608
assertThat (client .getProviderState ()).isEqualTo (ProviderState .STALE );
609
609
610
- // should run even thought handler was added after stale
610
+ // should run even though handler was added after stale
611
611
client .onProviderStale (handler );
612
612
verify (handler , timeout (TIMEOUT )).accept (any ());
613
613
}
@@ -623,13 +623,13 @@ void matchingErrorEventsMustRunImmediately() {
623
623
OpenFeatureAPI api = OpenFeatureAPI .getInstance ();
624
624
625
625
// provider which is already in error
626
- TestEventsProvider provider = new TestEventsProvider ();
626
+ TestEventsProvider provider = new TestEventsProvider (INIT_DELAY );
627
627
Client client = api .getClient (name );
628
628
api .setProviderAndWait (name , provider );
629
629
provider .emitProviderError (ProviderEventDetails .builder ().build ());
630
630
assertThat (client .getProviderState ()).isEqualTo (ProviderState .ERROR );
631
631
632
- // should run even thought handler was added after error
632
+ // should run even though handler was added after error
633
633
client .onProviderError (handler );
634
634
verify (handler , timeout (TIMEOUT )).accept (any ());
635
635
}
0 commit comments