# | Line 924 | Line 924 | public class PriorityBlockingQueue<E> ex | |
---|---|---|
924 | Object[] a = toArray(); | |
925 | return new PBQSpliterator(a, 0, a.length); | |
926 | } | |
927 | < | |
927 | > | |
928 | public Stream<E> stream() { | |
929 | int flags = Streams.STREAM_IS_SIZED; | |
930 | return Streams.stream | |
# | Line 949 | Line 949 | public class PriorityBlockingQueue<E> ex | |
949 | ||
950 | public PBQSpliterator<E> trySplit() { | |
951 | int lo = index, mid = (lo + fence) >>> 1; | |
952 | < | return (lo >= mid)? null : |
952 | > | return (lo >= mid) ? null : |
953 | new PBQSpliterator<E>(array, lo, index = mid); | |
954 | } | |
955 |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |