From 6b9ea117d3f0fa1db8304901e9a77c1b54fe36fe Mon Sep 17 00:00:00 2001 From: Clement Escoffier Date: Fri, 12 Mar 2021 07:49:11 +0100 Subject: [PATCH] Fix missing awaitFailure in MultiGroupTest --- .../java/io/smallrye/mutiny/operators/MultiGroupTest.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/implementation/src/test/java/io/smallrye/mutiny/operators/MultiGroupTest.java b/implementation/src/test/java/io/smallrye/mutiny/operators/MultiGroupTest.java index 05b5ca6b5..b2c090f4a 100644 --- a/implementation/src/test/java/io/smallrye/mutiny/operators/MultiGroupTest.java +++ b/implementation/src/test/java/io/smallrye/mutiny/operators/MultiGroupTest.java @@ -896,8 +896,12 @@ public void testGroupByWithUpstreamFailure() { emitter.get().fail(new TestException("boom")); - s1.assertFailedWith(TestException.class, "boom"); - s2.assertFailedWith(TestException.class, "boom"); + s1 + .awaitFailure() + .assertFailedWith(TestException.class, "boom"); + s2 + .awaitFailure() + .assertFailedWith(TestException.class, "boom"); subscriber.assertFailedWith(TestException.class, "boom"); }