Lines Matching refs:spliterator
71 * Creates a slice spliterator given a stream shape governing the
72 * spliterator type. Requires that the underlying Spliterator
133 public <P_IN> Spliterator<T> opEvaluateParallelLazy(PipelineHelper<T> helper, Spliterator<P_IN> spliterator) {
134 long size = helper.exactOutputSizeIfKnown(spliterator);
135 if (size > 0 && spliterator.hasCharacteristics(Spliterator.SUBSIZED)) {
137 helper.wrapSpliterator(spliterator),
142 helper.wrapSpliterator(spliterator),
154 return new SliceTask<>(this, helper, spliterator, castingArray(), skip, limit).
155 invoke().spliterator();
161 Spliterator<P_IN> spliterator,
163 long size = helper.exactOutputSizeIfKnown(spliterator);
164 if (size > 0 && spliterator.hasCharacteristics(Spliterator.SUBSIZED)) {
165 // Because the pipeline is SIZED the slice spliterator
168 // than creating the slice spliterator from the pipeline
169 // wrapping spliterator
170 Spliterator<P_IN> s = sliceSpliterator(helper.getSourceShape(), spliterator, skip, limit);
174 helper.wrapSpliterator(spliterator),
177 // can be used with the pipeline wrapping spliterator
178 // Note that we cannot create a slice spliterator from
179 // the source spliterator if the pipeline is not SIZED
183 return new SliceTask<>(this, helper, spliterator, generator, skip, limit).
250 Spliterator<P_IN> spliterator) {
251 long size = helper.exactOutputSizeIfKnown(spliterator);
252 if (size > 0 && spliterator.hasCharacteristics(Spliterator.SUBSIZED)) {
254 (Spliterator.OfInt) helper.wrapSpliterator(spliterator),
259 (Spliterator.OfInt) helper.wrapSpliterator(spliterator),
263 return new SliceTask<>(this, helper, spliterator, Integer[]::new, skip, limit).
264 invoke().spliterator();
270 Spliterator<P_IN> spliterator,
272 long size = helper.exactOutputSizeIfKnown(spliterator);
273 if (size > 0 && spliterator.hasCharacteristics(Spliterator.SUBSIZED)) {
274 // Because the pipeline is SIZED the slice spliterator
277 // than creating the slice spliterator from the pipeline
278 // wrapping spliterator
279 Spliterator<P_IN> s = sliceSpliterator(helper.getSourceShape(), spliterator, skip, limit);
283 (Spliterator.OfInt) helper.wrapSpliterator(spliterator),
286 // can be used with the pipeline wrapping spliterator
287 // Note that we cannot create a slice spliterator from
288 // the source spliterator if the pipeline is not SIZED
292 return new SliceTask<>(this, helper, spliterator, generator, skip, limit).
359 Spliterator<P_IN> spliterator) {
360 long size = helper.exactOutputSizeIfKnown(spliterator);
361 if (size > 0 && spliterator.hasCharacteristics(Spliterator.SUBSIZED)) {
363 (Spliterator.OfLong) helper.wrapSpliterator(spliterator),
368 (Spliterator.OfLong) helper.wrapSpliterator(spliterator),
372 return new SliceTask<>(this, helper, spliterator, Long[]::new, skip, limit).
373 invoke().spliterator();
379 Spliterator<P_IN> spliterator,
381 long size = helper.exactOutputSizeIfKnown(spliterator);
382 if (size > 0 && spliterator.hasCharacteristics(Spliterator.SUBSIZED)) {
383 // Because the pipeline is SIZED the slice spliterator
386 // than creating the slice spliterator from the pipeline
387 // wrapping spliterator
388 Spliterator<P_IN> s = sliceSpliterator(helper.getSourceShape(), spliterator, skip, limit);
392 (Spliterator.OfLong) helper.wrapSpliterator(spliterator),
395 // can be used with the pipeline wrapping spliterator
396 // Note that we cannot create a slice spliterator from
397 // the source spliterator if the pipeline is not SIZED
401 return new SliceTask<>(this, helper, spliterator, generator, skip, limit).
468 Spliterator<P_IN> spliterator) {
469 long size = helper.exactOutputSizeIfKnown(spliterator);
470 if (size > 0 && spliterator.hasCharacteristics(Spliterator.SUBSIZED)) {
472 (Spliterator.OfDouble) helper.wrapSpliterator(spliterator),
477 (Spliterator.OfDouble) helper.wrapSpliterator(spliterator),
481 return new SliceTask<>(this, helper, spliterator, Double[]::new, skip, limit).
482 invoke().spliterator();
488 Spliterator<P_IN> spliterator,
490 long size = helper.exactOutputSizeIfKnown(spliterator);
491 if (size > 0 && spliterator.hasCharacteristics(Spliterator.SUBSIZED)) {
492 // Because the pipeline is SIZED the slice spliterator
495 // than creating the slice spliterator from the pipeline
496 // wrapping spliterator
497 Spliterator<P_IN> s = sliceSpliterator(helper.getSourceShape(), spliterator, skip, limit);
501 (Spliterator.OfDouble) helper.wrapSpliterator(spliterator),
504 // can be used with the pipeline wrapping spliterator
505 // Note that we cannot create a slice spliterator from
506 // the source spliterator if the pipeline is not SIZED
510 return new SliceTask<>(this, helper, spliterator, generator, skip, limit).
570 Spliterator<P_IN> spliterator,
573 super(helper, spliterator);
580 SliceTask(SliceTask<P_IN, P_OUT> parent, Spliterator<P_IN> spliterator) {
581 super(parent, spliterator);
589 protected SliceTask<P_IN, P_OUT> makeChild(Spliterator<P_IN> spliterator) {
590 return new SliceTask<>(this, spliterator);
602 ? op.exactOutputSizeIfKnown(spliterator)
606 helper.copyIntoWithCancel(helper.wrapSink(opSink), spliterator);
613 spliterator).build();
616 spliterator = null;