Searched refs:terminalOp (Results 1 – 2 of 2) sorted by relevance
228 final <R> R evaluate(TerminalOp<E_OUT, R> terminalOp) { in evaluate() argument229 assert getOutputShape() == terminalOp.inputShape(); in evaluate()235 ? terminalOp.evaluateParallel(this, sourceSpliterator(terminalOp.getOpFlags())) in evaluate()236 : terminalOp.evaluateSequential(this, sourceSpliterator(terminalOp.getOpFlags())); in evaluate()
262 Consumer<Stream<Integer>> terminalOp = terminalOps.get(i); in testSplitting() local271 terminalOp.accept(s); in testSplitting()356 Consumer<IntStream> terminalOp = terminalOps.get(i); in testIntSplitting() local367 terminalOp.accept(s); in testIntSplitting()448 Consumer<LongStream> terminalOp = terminalOps.get(i); in testLongSplitting() local460 terminalOp.accept(s); in testLongSplitting()541 Consumer<DoubleStream> terminalOp = terminalOps.get(i); in testDoubleSplitting() local553 terminalOp.accept(s); in testDoubleSplitting()