| Modifier and Type | Class and Description |
|---|---|
| pack-priv static class | |
| pack-priv static class |
| Modifier and Type | Field and Description |
|---|---|
| private static final int | |
| pack-priv final Gatherer | |
| private static final int | |
| private static final int |
| Access | Constructor and Description |
|---|---|
| private | |
| private |
| Modifier and Type | Method and Description |
|---|---|
| public <CR, CA> CR | collect(Collector<? super R, CA, CR> c)
Overrides java. Implements java. Performs a mutable
reduction operation on the elements of this stream using a
|
| public <RR> RR | collect(Supplier<RR> supplier, BiConsumer<RR, ? super R> accumulator, BiConsumer<RR, RR> combiner)
Overrides java. Implements java. Performs a mutable reduction operation on the elements of this stream. |
| private <CA, CR> CR | evaluate(final Spliterator<T> spliterator, final boolean parallel, final Gatherer<T, A, R> gatherer, final Supplier<CA> collectorSupplier, final BiConsumer<CA, ? super R> collectorAccumulator, final BinaryOperator<CA> collectorCombiner, final Function<CA, CR> collectorFinisher)
|
| pack-priv static <P_IN, P_OUT extends T, T, A, R> Stream | |
| pack-priv <I> Node | opEvaluateParallel(PipelineHelper<R> unused1, Spliterator<I> spliterator, IntFunction<R[]> unused2)
Overrides java. Performs a parallel evaluation of the operation using the specified
|
| pack-priv <P_IN> Spliterator | opEvaluateParallelLazy(PipelineHelper<R> helper, Spliterator<P_IN> spliterator)
Overrides java. Returns a |
| private static int | |
| pack-priv boolean | opIsStateful()
Implements abstract java. Returns whether this operation is stateful or not. |
| pack-priv Sink | opWrapSink(int flags, Sink<R> downstream)
Implements abstract java. Accepts a |
| private AbstractPipeline |
| DEFAULT_FLAGS | back to summary |
|---|---|
| private static final int DEFAULT_FLAGS | |
| gatherer | back to summary |
|---|---|
| pack-priv final Gatherer<T, A, R> gatherer | |
| GREEDY_FLAGS | back to summary |
|---|---|
| private static final int GREEDY_FLAGS | |
| SHORT_CIRCUIT_FLAGS | back to summary |
|---|---|
| private static final int SHORT_CIRCUIT_FLAGS | |
| GathererOp | back to summary |
|---|---|
| private GathererOp(ReferencePipeline<?, T> upstream, Gatherer<T, A, R> gatherer) | |
| GathererOp | back to summary |
|---|---|
private GathererOp(Gatherer<T, A, R> gatherer, GathererOp<?, ?, T> upstream)
| |
| collect | back to summary |
|---|---|
| public <CR, CA> CR collect(Collector<? super R, CA, CR> c) Overrides java. Implements java. Doc from java. Performs a mutable
reduction operation on the elements of this stream using a
If the stream is parallel, and the This is a terminal operation. When executed in parallel, multiple intermediate results may be
instantiated, populated, and merged so as to maintain isolation of
mutable data structures. Therefore, even when executed in parallel
with non-thread-safe data structures (such as
| |
| collect | back to summary |
|---|---|
| public <RR> RR collect(Supplier<RR> supplier, BiConsumer<RR, ? super R> accumulator, BiConsumer<RR, RR> combiner) Overrides java. Implements java. Doc from java. Performs a mutable
reduction operation on the elements of this stream. A mutable
reduction is one in which the reduced value is a mutable result container,
such as an
Like This is a terminal operation.
| |
| evaluate | back to summary |
|---|---|
| private <CA, CR> CR evaluate(final Spliterator<T> spliterator, final boolean parallel, final Gatherer<T, A, R> gatherer, final Supplier<CA> collectorSupplier, final BiConsumer<CA, ? super R> collectorAccumulator, final BinaryOperator<CA> collectorCombiner, final Function<CA, CR> collectorFinisher) | |
| of | back to summary |
|---|---|
pack-priv static <P_IN, P_OUT extends T, T, A, R> Stream
| |
| opEvaluateParallel | back to summary |
|---|---|
| pack-priv <I> Node Overrides java. Doc from java. Performs a parallel evaluation of the operation using the specified
| |
| opEvaluateParallelLazy | back to summary |
|---|---|
| pack-priv <P_IN> Spliterator Overrides java. Doc from java. Returns a
| |
| opFlagsFor | back to summary |
|---|---|
| private static int opFlagsFor(Gatherer. | |
| opIsStateful | back to summary |
|---|---|
| pack-priv boolean opIsStateful() Implements abstract java. Doc from java. Returns whether this operation is stateful or not. If it is stateful,
then the method
| |
| opWrapSink | back to summary |
|---|---|
| pack-priv Sink Implements abstract java. Doc from java. Accepts a
| |
| upstream | back to summary |
|---|---|
private AbstractPipeline
| |
| Modifier and Type | Field and Description |
|---|---|
| private boolean | |
| private final Gatherer | |
| private final Gatherer. | |
| private boolean | |
| private final Sink | |
| private A |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public void | accept(T t)
Implements java. Performs this operation on the given argument. |
| public void | begin(long size)
Overrides default java. Resets the sink state to receive a fresh data set. |
| public boolean | cancellationRequested()
Overrides default java. Indicates that this |
| private boolean | |
| public void | |
| public boolean | isRejecting()
Overrides default java. Checks whether the next stage is known to not want any more elements sent to it. |
| public boolean | push(R r)
Implements java. Pushes, if possible, the provided element downstream -- to the next stage in the pipeline. |
| downstreamProceed | back to summary |
|---|---|
| private boolean downstreamProceed | |
| gatherer | back to summary |
|---|---|
| private final Gatherer<T, A, R> gatherer | |
| integrator | back to summary |
|---|---|
| private final Gatherer. | |
| proceed | back to summary |
|---|---|
| private boolean proceed | |
| sink | back to summary |
|---|---|
| private final Sink<R> sink | |
| state | back to summary |
|---|---|
| private A state | |
| GatherSink | back to summary |
|---|---|
| pack-priv GatherSink(Gatherer<T, A, R> gatherer, Sink<R> sink) | |
| accept | back to summary |
|---|---|
| public void accept(T t) Implements java. Doc from java. Performs this operation on the given argument.
| |
| begin | back to summary |
|---|---|
| public void begin(long size) Overrides default java. Doc from java. Resets the sink state to receive a fresh data set. This must be called
before sending any data to the sink. After calling
| |
| cancellationRequested | back to summary |
|---|---|
| public boolean cancellationRequested() Overrides default java. Doc from java. Indicates that this
| |
| cancellationRequested | back to summary |
|---|---|
| private boolean cancellationRequested(boolean knownProceed) | |
| end | back to summary |
|---|---|
| public void end() Overrides default java. Doc from java. Indicates that all elements have been pushed. If the Prior to this call, the sink must be in the active state, and after this call it is returned to the initial state.
| |
| isRejecting | back to summary |
|---|---|
| public boolean isRejecting() Overrides default java. Doc from java. Checks whether the next stage is known to not want any more elements sent to it.
| |
| push | back to summary |
|---|---|
| public boolean push(R r) Implements java. Doc from java. Pushes, if possible, the provided element downstream -- to the next stage in the pipeline.
| |
| Modifier and Type | Class and Description |
|---|---|
| pack-priv static class |
| Modifier and Type | Field and Description |
|---|---|
| private Node | |
| private static final int | |
| private GathererOp. |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public void | accept(X x)
Implements java. Performs this operation on the given argument. |
| public Node | |
| private boolean | |
| public GathererOp. |
| leftMost | back to summary |
|---|---|
| private Node<X> leftMost | |
| LINEAR_APPEND_MAX | back to summary |
|---|---|
| private static final int LINEAR_APPEND_MAX | |
| rightMost | back to summary |
|---|---|
| private GathererOp. | |
| NodeBuilder | back to summary |
|---|---|
| pack-priv NodeBuilder() | |
| accept | back to summary |
|---|---|
| public void accept(X x) Implements java. Doc from java. Performs this operation on the given argument.
| |
| build | back to summary |
|---|---|
| public Node | |
| isEmpty | back to summary |
|---|---|
| private boolean isEmpty() | |
| join | back to summary |
|---|---|
| public GathererOp. | |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Builder | back to summary |
|---|---|
| pack-priv Builder() | |