Remove calls to .pollInSameThread() as Awaitility has been configured…

… to do so by default
smallrye · Dec 6, 2021 · c30df63 · c30df63
1 parent a1fbbe5
commit c30df63
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/implementation/src/test/java/io/smallrye/mutiny/subscription/SerializedSubscriberTest.java b/implementation/src/test/java/io/smallrye/mutiny/subscription/SerializedSubscriberTest.java
@@ -387,7 +387,7 @@ public void testOnCompleteOnErrorRace() {
  Collections.shuffle(runnables);
  runnables.forEach(r -> new Thread(r).start());
 
- Awaitility.await().pollInSameThread().until(() -> subscriber.hasCompleted() || subscriber.getFailure() != null);
+ Awaitility.await().until(() -> subscriber.hasCompleted() || subscriber.getFailure() != null);
  if (subscriber.hasCompleted()) {
  subscriber.assertCompleted().assertHasNotReceivedAnyItem();
  } else {

diff --git a/implementation/src/test/java/io/smallrye/mutiny/unchecked/UncheckedConsumerTest.java b/implementation/src/test/java/io/smallrye/mutiny/unchecked/UncheckedConsumerTest.java
@@ -84,7 +84,7 @@ public void testSubscription() {
  reference.set(s);
  }));
 
- await().pollInSameThread().until(() -> reference.get() != null);
+ await().until(() -> reference.get() != null);
  assertThat(reference).hasValue("hey");
  }