@Test(timeOut = 1000L) public void testWaitUntilComplete() throws Exception { new ParallelJobsFuture(successJobFutures(4)).waitUntilComplete(); }
@Override public void waitUntilComplete() { forEachFuture(JobFuture::waitUntilComplete); }
ParallelJobsFuture implements JobFuture { @Override public void waitUntilComplete() { forEachFuture(JobFuture::waitUntilComplete); } }
ParallelJobsFuture implements JobFuture { @Override public void waitUntilComplete() { forEachFuture(JobFuture::waitUntilComplete); } ParallelJobsFuture(JobFuture... jobs);  ParallelJobsFuture(List<JobFuture> jobs);  ParallelJobsFuture(List<JobInfo> jobInfoList, QueueClient queueClient); }
ParallelJobsFuture implements JobFuture { @Override public void waitUntilComplete() { forEachFuture(JobFuture::waitUntilComplete); } ParallelJobsFuture(JobFuture... jobs);  ParallelJobsFuture(List<JobFuture> jobs);  ParallelJobsFuture(List<JobInfo> jobInfoList, QueueClient queueClient); @Override void waitUntilComplete(); @Override void waitUntilComplete(Duration timeout); @Override CompletableFuture<Void> waitAsync(); }
ParallelJobsFuture implements JobFuture { @Override public void waitUntilComplete() { forEachFuture(JobFuture::waitUntilComplete); } ParallelJobsFuture(JobFuture... jobs);  ParallelJobsFuture(List<JobFuture> jobs);  ParallelJobsFuture(List<JobInfo> jobInfoList, QueueClient queueClient); @Override void waitUntilComplete(); @Override void waitUntilComplete(Duration timeout); @Override CompletableFuture<Void> waitAsync();  }