Searched refs:sourceSpliterator (Results 1 – 1 of 1) sorted by relevance
124 private Spliterator<?> sourceSpliterator; field in AbstractPipeline184 this.sourceSpliterator = source; in AbstractPipeline()234 ? terminalOp.evaluateParallel(this, sourceSpliterator(terminalOp.getOpFlags())) in evaluate()235 : terminalOp.evaluateSequential(this, sourceSpliterator(terminalOp.getOpFlags())); in evaluate()258 return opEvaluateParallel(previousStage, previousStage.sourceSpliterator(0), generator); in evaluateToArrayNode()261 return evaluate(sourceSpliterator(0), true, generator); in evaluateToArrayNode()283 if (sourceStage.sourceSpliterator != null) { in sourceStageSpliterator()285 Spliterator<E_OUT> s = sourceStage.sourceSpliterator; in sourceStageSpliterator()286 sourceStage.sourceSpliterator = null; in sourceStageSpliterator()320 sourceSpliterator = null; in close()[all …]