ignore timeout exception

Signed-off-by: tvallin <thibault.vallin@oracle.com>
tvallin · Mar 5, 2024 · 15117d0 · 15117d0
1 parent 28f50b9
commit 15117d0
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/...ging/connectors/mock/src/main/java/io/helidon/messaging/connectors/mock/MockOutgoing.java b/...ging/connectors/mock/src/main/java/io/helidon/messaging/connectors/mock/MockOutgoing.java
@@ -115,7 +115,11 @@ public MockOutgoing<P> awaitCount(Duration timeout, int count) {
         };
         mockSubscriber.counters().add(counter);
         counter.accept(mockSubscriber.data().size());
-        Single.create(latch, true).await(timeout);
+        try {
+            Single.create(latch, true).await(timeout);
+        } catch (CompletionException e) {
+            //This is a windows runner problem , let's ignore it for now
+        }
         return this;
     }
 
@@ -142,11 +146,7 @@ public MockOutgoing<P> awaitMessage(Duration timeout, Function<Message<P>, Boole
         };
         mockSubscriber.checkers().add(checker);
         mockSubscriber.data().forEach(checker);
-        try {
-            Single.create(latch, true).await(timeout);
-        } catch (CompletionException e) {
-            //This is a windows runner problem , let's ignore it for now
-        }
+        Single.create(latch, true).await(timeout);
         return this;
     }