# | Line 979 | Line 979 | public class PriorityBlockingQueue<E> ex | |
---|---|---|
979 | } | |
980 | } | |
981 | ||
982 | < | Spliterator<E> spliterator() { |
982 | > | public Spliterator<E> spliterator() { |
983 | return new PBQSpliterator<E>(this, null, 0, -1); | |
984 | } | |
985 | – | public Stream<E> stream() { |
986 | – | return Streams.stream(spliterator()); |
987 | – | } |
988 | – | public Stream<E> parallelStream() { |
989 | – | return Streams.parallelStream(spliterator()); |
990 | – | } |
985 | ||
986 | // Unsafe mechanics | |
987 | private static final sun.misc.Unsafe UNSAFE; |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |