845 |
|
immediates.forEach( |
846 |
|
f -> assertTrue(((ScheduledFuture)f).getDelay(NANOSECONDS) <= 0L)); |
847 |
|
|
848 |
< |
Stream.of(immediates, delayeds, periodics).flatMap(c -> c.stream()) |
848 |
> |
Stream.of(immediates, delayeds, periodics).flatMap(Collection::stream) |
849 |
|
.forEach(f -> assertFalse(f.isDone())); |
850 |
|
|
851 |
|
try { p.shutdown(); } catch (SecurityException ok) { return; } |
899 |
|
|
900 |
|
assertTrue(q.isEmpty()); |
901 |
|
|
902 |
< |
Stream.of(immediates, delayeds, periodics).flatMap(c -> c.stream()) |
902 |
> |
Stream.of(immediates, delayeds, periodics).flatMap(Collection::stream) |
903 |
|
.forEach(f -> assertTrue(f.isDone())); |
904 |
|
|
905 |
|
for (Future<?> f : immediates) assertNull(f.get()); |