public static class CollectorOps.TestParallelSizedOp.OfInt extends CollectorOps.TestParallelSizedOp<Integer>
CollectorOps.TestParallelSizedOp.OfDouble, CollectorOps.TestParallelSizedOp.OfInt, CollectorOps.TestParallelSizedOp.OfLong
Constructor and Description |
---|
OfInt() |
Modifier and Type | Method and Description |
---|---|
static <T> AbstractPipeline |
chain(AbstractPipeline upstream,
org.openjdk.testlib.java.util.stream.IntermediateTestOp<?,T> op) |
static <T> AbstractPipeline |
chain(AbstractPipeline upstream,
org.openjdk.testlib.java.util.stream.StatefulTestOp op) |
default <P_IN> Spliterator<E> |
opEvaluateParallelLazy(PipelineHelper<E> helper,
Spliterator<P_IN> spliterator) |
opEvaluateParallel
inputShape, opGetFlags, opWrapSink, outputShape
public static <T> AbstractPipeline chain(AbstractPipeline upstream, org.openjdk.testlib.java.util.stream.StatefulTestOp op)
public <P_IN> Spliterator<E> opEvaluateParallelLazy(PipelineHelper<E> helper, Spliterator<P_IN> spliterator)
public static <T> AbstractPipeline chain(AbstractPipeline upstream, org.openjdk.testlib.java.util.stream.IntermediateTestOp<?,T> op)