Lines Matching refs:spliterator
119 * The source spliterator. Only valid for the head pipeline.
266 * Gets the source stage spliterator if this pipeline stage is the source
270 * @return the source stage spliterator
342 public Spliterator<E_OUT> spliterator() {
388 * Get the source spliterator for this pipeline stage. For a sequential or
389 * stateless parallel pipeline, this is the source spliterator. For a
390 * stateful parallel pipeline, this is a spliterator describing the results
396 // Get the source spliterator of the pipeline
397 Spliterator<?> spliterator = null;
399 spliterator = sourceStage.sourceSpliterator;
403 spliterator = (Spliterator<?>) sourceStage.sourceSupplier.get();
411 // Adapt the source spliterator, evaluating each stateful op
427 // if so spliterator.forEachRemaining should be used
432 spliterator = p.opEvaluateParallelLazy(u, spliterator);
435 // based on the stage's spliterator
436 thisOpFlags = spliterator.hasCharacteristics(Spliterator.SIZED)
450 return spliterator;
466 final <P_IN> long exactOutputSizeIfKnown(Spliterator<P_IN> spliterator) {
467 return StreamOpFlag.SIZED.isKnown(getStreamAndOpFlags()) ? spliterator.getExactSizeIfKnown() : -1;
471 final <P_IN, S extends Sink<E_OUT>> S wrapAndCopyInto(S sink, Spliterator<P_IN> spliterator) {
472 copyInto(wrapSink(Objects.requireNonNull(sink)), spliterator);
477 final <P_IN> void copyInto(Sink<P_IN> wrappedSink, Spliterator<P_IN> spliterator) {
481 wrappedSink.begin(spliterator.getExactSizeIfKnown());
482 spliterator.forEachRemaining(wrappedSink);
486 copyIntoWithCancel(wrappedSink, spliterator);
492 final <P_IN> void copyIntoWithCancel(Sink<P_IN> wrappedSink, Spliterator<P_IN> spliterator) {
498 wrappedSink.begin(spliterator.getExactSizeIfKnown());
499 p.forEachWithCancel(spliterator, wrappedSink);
536 public final <P_IN> Node<E_OUT> evaluate(Spliterator<P_IN> spliterator,
541 return evaluateToNode(this, spliterator, flatten, generator);
545 exactOutputSizeIfKnown(spliterator), generator);
546 return wrapAndCopyInto(nb, spliterator).build();
568 * @param spliterator the source spliterator
574 Spliterator<P_IN> spliterator,
579 * Create a spliterator that wraps a source spliterator, compatible with
584 * @param supplier the supplier of a spliterator
585 * @return a wrapping spliterator compatible with this shape
592 * Create a lazy spliterator that wraps and obtains the supplied the
593 * spliterator when a method is invoked on the lazy spliterator.
594 * @param supplier the supplier of a spliterator
599 * Traverse the elements of a spliterator compatible with this stream shape,
603 * @param spliterator the spliterator to pull elements from
606 public abstract void forEachWithCancel(Spliterator<E_OUT> spliterator, Sink<E_OUT> sink);
672 * @param spliterator the source {@code Spliterator}
677 Spliterator<P_IN> spliterator,
688 * lazily evaluated spliterator.
693 * Object[i]).spliterator();
699 * @param spliterator the source {@code Spliterator}
704 Spliterator<P_IN> spliterator) {
705 return opEvaluateParallel(helper, spliterator, i -> (E_OUT[]) new Object[i]).spliterator();