We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent eb3f3e6 commit cac2b30Copy full SHA for cac2b30
utils/src/test/java/software/amazon/awssdk/utils/async/StoringSubscriberTest.java
@@ -159,8 +159,6 @@ public void cancel() {
159
}
160
};
161
162
- subscriber.onSubscribe(subscription);
163
-
164
Future<Object> consumerFuture = consumer.submit(() -> {
165
int expectedMessageNumber = 0;
166
while (testRunning.get()) {
@@ -183,6 +181,8 @@ public void cancel() {
183
181
return null;
184
182
});
185
+ subscriber.onSubscribe(subscription);
+
186
Thread.sleep(5_000);
187
testRunning.set(false);
188
consumerFuture.get();
0 commit comments