Lines Matching refs:spliterator
33 import java.util.Spliterator;
98 * spliterator obtained from the concatenated node preserves the encounter
301 * {@link Spliterator} has the {@link Spliterator#SUBSIZED} characteristic,
317 Spliterator<P_IN> spliterator,
320 long size = helper.exactOutputSizeIfKnown(spliterator);
321 if (size >= 0 && spliterator.hasCharacteristics(Spliterator.SUBSIZED)) {
325 new SizedCollectorTask.OfRef<>(spliterator, helper, array).invoke();
328 Node<P_OUT> node = new CollectorTask.OfRef<>(helper, generator, spliterator).invoke();
339 * {@link Spliterator} has the {@link Spliterator#SUBSIZED} characteristic,
348 * @param <P_IN> the type of elements from the source Spliterator
355 Spliterator<P_IN> spliterator,
357 long size = helper.exactOutputSizeIfKnown(spliterator);
358 if (size >= 0 && spliterator.hasCharacteristics(Spliterator.SUBSIZED)) {
362 new SizedCollectorTask.OfInt<>(spliterator, helper, array).invoke();
366 Node.OfInt node = new CollectorTask.OfInt<>(helper, spliterator).invoke();
377 * {@link Spliterator} has the {@link Spliterator#SUBSIZED} characteristic,
386 * @param <P_IN> the type of elements from the source Spliterator
393 Spliterator<P_IN> spliterator,
395 long size = helper.exactOutputSizeIfKnown(spliterator);
396 if (size >= 0 && spliterator.hasCharacteristics(Spliterator.SUBSIZED)) {
400 new SizedCollectorTask.OfLong<>(spliterator, helper, array).invoke();
404 Node.OfLong node = new CollectorTask.OfLong<>(helper, spliterator).invoke();
415 * {@link Spliterator} has the {@link Spliterator#SUBSIZED} characteristic,
424 * @param <P_IN> the type of elements from the source Spliterator
431 Spliterator<P_IN> spliterator,
433 long size = helper.exactOutputSizeIfKnown(spliterator);
434 if (size >= 0 && spliterator.hasCharacteristics(Spliterator.SUBSIZED)) {
438 new SizedCollectorTask.OfDouble<>(spliterator, helper, array).invoke();
442 Node.OfDouble node = new CollectorTask.OfDouble<>(helper, spliterator).invoke();
580 public Spliterator<T> spliterator() {
592 public Spliterator.OfInt spliterator() {
609 public Spliterator.OfLong spliterator() {
626 public Spliterator.OfDouble spliterator() {
658 public Spliterator<T> spliterator() {
659 return Arrays.spliterator(array, 0, curSize);
708 public Spliterator<T> spliterator() {
709 return c.stream().spliterator();
753 // The Node count will be required when the Node spliterator is
787 public Spliterator<T> spliterator() {
841 T_SPLITR extends Spliterator.OfPrimitive<E, T_CONS, T_SPLITR>,
884 extends ConcNode.OfPrimitive<Integer, IntConsumer, int[], Spliterator.OfInt, Node.OfInt>
892 public Spliterator.OfInt spliterator() {
898 extends ConcNode.OfPrimitive<Long, LongConsumer, long[], Spliterator.OfLong, Node.OfLong>
906 public Spliterator.OfLong spliterator() {
912 extends ConcNode.OfPrimitive<Double, DoubleConsumer, double[], Spliterator.OfDouble, Node.OfDouble>
920 public Spliterator.OfDouble spliterator() {
926 /** Abstract class for spliterator for all internal node classes */
928 S extends Spliterator<T>,
930 implements Spliterator<T> {
938 // The spliterator of the curNode if that node is last and has no children.
939 // This spliterator will be delegated to for splitting and traversing.
943 // spliterator used while traversing with tryAdvance
957 * covered by this spliterator
1000 tryAdvanceSpliterator = (S) leaf.spliterator();
1022 return (S) curNode.getChild(curChildIndex++).spliterator();
1026 lastNodeSpliterator = (S) curNode.spliterator();
1031 return (S) curNode.getChild(curChildIndex++).spliterator();
1055 return Spliterator.SIZED;
1059 extends InternalNodeSpliterator<T, Spliterator<T>, Node<T>> {
1073 // Advance to the spliterator of the next non-empty leaf node
1076 tryAdvanceSpliterator = leaf.spliterator();
1077 // Since the node is not-empty the spliterator can be advanced
1110 T_SPLITR extends Spliterator.OfPrimitive<T, T_CONS, T_SPLITR>,
1113 implements Spliterator.OfPrimitive<T, T_CONS, T_SPLITR> {
1127 // Advance to the spliterator of the next non-empty leaf node
1130 tryAdvanceSpliterator = leaf.spliterator();
1131 // Since the node is not-empty the spliterator can be advanced
1164 extends OfPrimitive<Integer, IntConsumer, int[], Spliterator.OfInt, Node.OfInt>
1165 implements Spliterator.OfInt {
1173 extends OfPrimitive<Long, LongConsumer, long[], Spliterator.OfLong, Node.OfLong>
1174 implements Spliterator.OfLong {
1182 extends OfPrimitive<Double, DoubleConsumer, double[], Spliterator.OfDouble, Node.OfDouble>
1183 implements Spliterator.OfDouble {
1254 public Spliterator<T> spliterator() {
1256 return super.spliterator();
1331 public Spliterator.OfInt spliterator() {
1332 return Arrays.spliterator(array, 0, curSize);
1385 public Spliterator.OfLong spliterator() {
1386 return Arrays.spliterator(array, 0, curSize);
1439 public Spliterator.OfDouble spliterator() {
1440 return Arrays.spliterator(array, 0, curSize);
1646 public Spliterator.OfInt spliterator() {
1648 return super.spliterator();
1706 public Spliterator.OfLong spliterator() {
1708 return super.spliterator();
1766 public Spliterator.OfDouble spliterator() {
1768 return super.spliterator();
1826 protected final Spliterator<P_IN> spliterator;
1834 SizedCollectorTask(Spliterator<P_IN> spliterator,
1837 assert spliterator.hasCharacteristics(Spliterator.SUBSIZED);
1838 this.spliterator = spliterator;
1840 this.targetSize = AbstractTask.suggestTargetSize(spliterator.estimateSize());
1845 SizedCollectorTask(K parent, Spliterator<P_IN> spliterator,
1848 assert spliterator.hasCharacteristics(Spliterator.SUBSIZED);
1849 this.spliterator = spliterator;
1865 Spliterator<P_IN> rightSplit = spliterator, leftSplit;
1882 abstract K makeChild(Spliterator<P_IN> spliterator, long offset, long size);
1901 OfRef(Spliterator<P_IN> spliterator, PipelineHelper<P_OUT> helper, P_OUT[] array) {
1902 super(spliterator, helper, array.length);
1906 OfRef(OfRef<P_IN, P_OUT> parent, Spliterator<P_IN> spliterator,
1908 super(parent, spliterator, offset, length, parent.array.length);
1913 OfRef<P_IN, P_OUT> makeChild(Spliterator<P_IN> spliterator,
1915 return new OfRef<>(this, spliterator, offset, size);
1933 OfInt(Spliterator<P_IN> spliterator, PipelineHelper<Integer> helper, int[] array) {
1934 super(spliterator, helper, array.length);
1938 OfInt(SizedCollectorTask.OfInt<P_IN> parent, Spliterator<P_IN> spliterator,
1940 super(parent, spliterator, offset, length, parent.array.length);
1945 SizedCollectorTask.OfInt<P_IN> makeChild(Spliterator<P_IN> spliterator,
1947 return new SizedCollectorTask.OfInt<>(this, spliterator, offset, size);
1965 OfLong(Spliterator<P_IN> spliterator, PipelineHelper<Long> helper, long[] array) {
1966 super(spliterator, helper, array.length);
1970 OfLong(SizedCollectorTask.OfLong<P_IN> parent, Spliterator<P_IN> spliterator,
1972 super(parent, spliterator, offset, length, parent.array.length);
1977 SizedCollectorTask.OfLong<P_IN> makeChild(Spliterator<P_IN> spliterator,
1979 return new SizedCollectorTask.OfLong<>(this, spliterator, offset, size);
1997 OfDouble(Spliterator<P_IN> spliterator, PipelineHelper<Double> helper, double[] array) {
1998 super(spliterator, helper, array.length);
2002 OfDouble(SizedCollectorTask.OfDouble<P_IN> parent, Spliterator<P_IN> spliterator,
2004 super(parent, spliterator, offset, length, parent.array.length);
2009 SizedCollectorTask.OfDouble<P_IN> makeChild(Spliterator<P_IN> spliterator,
2011 return new SizedCollectorTask.OfDouble<>(this, spliterator, offset, size);
2098 T_SPLITR extends Spliterator.OfPrimitive<T, T_CONS, T_SPLITR>,
2126 extends OfPrimitive<Integer, IntConsumer, int[], Spliterator.OfInt, Node.OfInt> {
2134 extends OfPrimitive<Long, LongConsumer, long[], Spliterator.OfLong, Node.OfLong> {
2142 extends OfPrimitive<Double, DoubleConsumer, double[], Spliterator.OfDouble, Node.OfDouble> {
2157 Spliterator<P_IN> spliterator,
2160 super(helper, spliterator);
2167 Spliterator<P_IN> spliterator) {
2168 super(parent, spliterator);
2175 protected CollectorTask<P_IN, P_OUT, T_NODE, T_BUILDER> makeChild(Spliterator<P_IN> spliterator) {
2176 return new CollectorTask<>(this, spliterator);
2182 T_BUILDER builder = builderFactory.apply(helper.exactOutputSizeIfKnown(spliterator));
2183 return (T_NODE) helper.wrapAndCopyInto(builder, spliterator).build();
2198 Spliterator<P_IN> spliterator) {
2199 super(helper, spliterator, s -> builder(s, generator), ConcNode::new);
2206 OfInt(PipelineHelper<Integer> helper, Spliterator<P_IN> spliterator) {
2207 super(helper, spliterator, Nodes::intBuilder, ConcNode.OfInt::new);
2214 OfLong(PipelineHelper<Long> helper, Spliterator<P_IN> spliterator) {
2215 super(helper, spliterator, Nodes::longBuilder, ConcNode.OfLong::new);
2222 OfDouble(PipelineHelper<Double> helper, Spliterator<P_IN> spliterator) {
2223 super(helper, spliterator, Nodes::doubleBuilder, ConcNode.OfDouble::new);
