804 |
|
immediates.forEach( |
805 |
|
f -> assertTrue(((ScheduledFuture)f).getDelay(NANOSECONDS) <= 0L)); |
806 |
|
|
807 |
< |
Stream.of(immediates, delayeds, periodics).flatMap(c -> c.stream()) |
807 |
> |
Stream.of(immediates, delayeds, periodics).flatMap(Collection::stream) |
808 |
|
.forEach(f -> assertFalse(f.isDone())); |
809 |
|
|
810 |
|
try { p.shutdown(); } catch (SecurityException ok) { return; } |
858 |
|
|
859 |
|
assertTrue(q.isEmpty()); |
860 |
|
|
861 |
< |
Stream.of(immediates, delayeds, periodics).flatMap(c -> c.stream()) |
861 |
> |
Stream.of(immediates, delayeds, periodics).flatMap(Collection::stream) |
862 |
|
.forEach(f -> assertTrue(f.isDone())); |
863 |
|
|
864 |
|
for (Future<?> f : immediates) assertNull(f.get()); |