public static class CollectorOps.StatefulCollector<E_IN> extends Object
Constructor and Description |
---|
StatefulCollector(int opFlags,
StreamShape inputShape) |
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) |
StreamShape |
inputShape() |
<P_IN> Node<E_IN> |
opEvaluateParallel(PipelineHelper<E_IN> helper,
Spliterator<P_IN> spliterator,
IntFunction<E_IN[]> generator) |
default <P_IN> Spliterator<E> |
opEvaluateParallelLazy(PipelineHelper<E> helper,
Spliterator<P_IN> spliterator) |
int |
opGetFlags() |
Sink<E_IN> |
opWrapSink(int flags,
boolean parallel,
Sink<E_IN> sink) |
StreamShape |
outputShape() |
public StatefulCollector(int opFlags, StreamShape inputShape)
public StreamShape inputShape()
public StreamShape outputShape()
public int opGetFlags()
public <P_IN> Node<E_IN> opEvaluateParallel(PipelineHelper<E_IN> helper, Spliterator<P_IN> spliterator, IntFunction<E_IN[]> generator)
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)