Searched refs:sourceSpliterator (Results 1 – 1 of 1) sorted by relevance
125 private Spliterator<?> sourceSpliterator; field in AbstractPipeline185 this.sourceSpliterator = source; in AbstractPipeline()235 ? terminalOp.evaluateParallel(this, sourceSpliterator(terminalOp.getOpFlags())) in evaluate()236 : terminalOp.evaluateSequential(this, sourceSpliterator(terminalOp.getOpFlags())); in evaluate()260 return opEvaluateParallel(previousStage, previousStage.sourceSpliterator(0), generator); in evaluateToArrayNode()263 return evaluate(sourceSpliterator(0), true, generator); in evaluateToArrayNode()285 if (sourceStage.sourceSpliterator != null) { in sourceStageSpliterator()287 Spliterator<E_OUT> s = sourceStage.sourceSpliterator; in sourceStageSpliterator()288 sourceStage.sourceSpliterator = null; in sourceStageSpliterator()322 sourceSpliterator = null; in close()[all …]