diff --git a/utils/src/test/java/software/amazon/awssdk/utils/async/StoringSubscriberTest.java b/utils/src/test/java/software/amazon/awssdk/utils/async/StoringSubscriberTest.java index 569022d97cfd..773fa7576a18 100644 --- a/utils/src/test/java/software/amazon/awssdk/utils/async/StoringSubscriberTest.java +++ b/utils/src/test/java/software/amazon/awssdk/utils/async/StoringSubscriberTest.java @@ -159,8 +159,6 @@ public void cancel() { } }; - subscriber.onSubscribe(subscription); - Future consumerFuture = consumer.submit(() -> { int expectedMessageNumber = 0; while (testRunning.get()) { @@ -183,6 +181,8 @@ public void cancel() { return null; }); + subscriber.onSubscribe(subscription); + Thread.sleep(5_000); testRunning.set(false); consumerFuture.get();