public static class CollectorOps.TestParallelSizedOp<T> extends CollectorOps.StatefulCollector<T>
Modifier and Type | Class and Description |
---|---|
static class |
CollectorOps.TestParallelSizedOp.OfDouble |
static class |
CollectorOps.TestParallelSizedOp.OfInt |
static class |
CollectorOps.TestParallelSizedOp.OfLong |
Modifier | Constructor and Description |
---|---|
|
TestParallelSizedOp() |
protected |
TestParallelSizedOp(StreamShape shape) |
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) |
<P_IN> Node<T> |
opEvaluateParallel(PipelineHelper<T> helper,
Spliterator<P_IN> spliterator,
IntFunction<T[]> generator) |
default <P_IN> Spliterator<E> |
opEvaluateParallelLazy(PipelineHelper<E> helper,
Spliterator<P_IN> spliterator) |
inputShape, opGetFlags, opWrapSink, outputShape
public TestParallelSizedOp()
protected TestParallelSizedOp(StreamShape shape)
public <P_IN> Node<T> opEvaluateParallel(PipelineHelper<T> helper, Spliterator<P_IN> spliterator, IntFunction<T[]> generator)
opEvaluateParallel
in class CollectorOps.StatefulCollector<T>
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)