# | Line 1002 | Line 1002 | public class SubmissionPublisherTest ext | |
---|---|---|
1002 | public void onComplete() {} | |
1003 | } | |
1004 | pub.subscribe(new Sub()); | |
1005 | < | CompletableFuture.runAsync(() -> pub.submit(Boolean.TRUE)); |
1005 | > | checkTimedGet( |
1006 | > | CompletableFuture.runAsync(() -> pub.submit(Boolean.TRUE)), |
1007 | > | null); |
1008 | await(finished); | |
1009 | } | |
1010 | } |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |