< prev index next >
test/jdk/java/util/concurrent/tck/SubmissionPublisherTest.java
Print this page
8207003: Miscellaneous changes imported from jsr166 CVS 2018-09
Reviewed-by: martin, chegar
@@ -1027,9 +1027,11 @@
}
public void onError(Throwable t) { throw new AssertionError(t); }
public void onComplete() {}
}
pub.subscribe(new Sub());
- CompletableFuture.runAsync(() -> pub.submit(Boolean.TRUE));
+ checkTimedGet(
+ CompletableFuture.runAsync(() -> pub.submit(Boolean.TRUE)),
+ null);
await(finished);
}
}
< prev index next >