We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 679cdf6 commit 525bf58Copy full SHA for 525bf58
src/test/java/io/reactivex/internal/operators/maybe/MaybeUnsubscribeOnTest.java
@@ -47,6 +47,12 @@ public void run() throws Exception {
47
48
assertTrue(cdl.await(5, TimeUnit.SECONDS));
49
50
+ int times = 10;
51
+
52
+ while (times-- > 0 && pp.hasSubscribers()) {
53
+ Thread.sleep(100);
54
+ }
55
56
assertFalse(pp.hasSubscribers());
57
58
assertNotEquals(Thread.currentThread().getName(), name[0]);
0 commit comments