< 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,1035 **** } public void onError(Throwable t) { throw new AssertionError(t); } public void onComplete() {} } pub.subscribe(new Sub()); ! CompletableFuture.runAsync(() -> pub.submit(Boolean.TRUE)); await(finished); } } --- 1027,1037 ---- } public void onError(Throwable t) { throw new AssertionError(t); } public void onComplete() {} } pub.subscribe(new Sub()); ! checkTimedGet( ! CompletableFuture.runAsync(() -> pub.submit(Boolean.TRUE)), ! null); await(finished); } }
< prev index next >