Add sleep to Drop Emitter test bean

eclipse · Feb 22, 2024 · 29dfac9 · 29dfac9
1 parent 3e5afe3
commit 29dfac9
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/...se/microprofile/reactive/messaging/tck/channel/overflow/BeanWithFailOverflowStrategy.java b/...se/microprofile/reactive/messaging/tck/channel/overflow/BeanWithFailOverflowStrategy.java
@@ -95,10 +95,14 @@ public void emitALotOfItems() {
     @Outgoing("out")
     public PublisherBuilder<String> consume(final PublisherBuilder<String> values) {
         return values
-                .via(ReactiveStreams.<String>builder()
-                        .flatMapCompletionStage(s -> CompletableFuture.supplyAsync(() -> s, executor)))
-                .onError(err -> downstreamFailure = err);
-
+                .via(ReactiveStreams.<String>builder().flatMapCompletionStage(s -> CompletableFuture.supplyAsync(() -> {
+                    try {
+                        Thread.sleep(1);
+                    } catch (InterruptedException ignored) {
+                        Thread.currentThread().interrupt();
+                    }
+                    return s;
+                }, executor))).onError(err -> downstreamFailure = err);
     }
 
     @Incoming("out")