27 |
|
import java.util.stream.Stream; |
28 |
|
import java.util.Spliterator; |
29 |
|
import java.util.stream.Streams; |
30 |
< |
import java.util.function.Block; |
30 |
> |
import java.util.function.Consumer; |
31 |
|
|
32 |
|
/** |
33 |
|
* An unbounded priority {@linkplain Queue queue} based on a priority heap. |
823 |
|
expectedModCount); |
824 |
|
} |
825 |
|
|
826 |
< |
public void forEach(Block<? super E> block) { |
826 |
> |
public void forEach(Consumer<? super E> block) { |
827 |
|
Object[] a; int i, hi; // hoist accesses and checks from loop |
828 |
|
if (block == null) |
829 |
|
throw new NullPointerException(); |
839 |
|
} |
840 |
|
} |
841 |
|
|
842 |
< |
public boolean tryAdvance(Block<? super E> block) { |
842 |
> |
public boolean tryAdvance(Consumer<? super E> block) { |
843 |
|
if (index >= 0 && index < fence) { |
844 |
|
@SuppressWarnings("unchecked") E e = |
845 |
|
(E)pq.queue[index++]; |