Fix missing awaitFailure in MultiGroupTest

smallrye · Mar 12, 2021 · 6b9ea11 · 6b9ea11
1 parent 24ebf3a
commit 6b9ea11
Showing 1 changed file with 6 additions and 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
@@ -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");
     }