Class CollapseSpliterator<T,R>

java.lang.Object

one.util.streamex.Internals.Box<T>

one.util.streamex.CollapseSpliterator<T,R>

All Implemented Interfaces:

Consumer<T>, Spliterator<R>

final class CollapseSpliterator<T,R>
extends Internals.Box<T>
implements Spliterator<R>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	CollapseSpliterator.Connector<T,R>

Nested classes/interfaces inherited from interface Spliterator

Spliterator.OfDouble, Spliterator.OfInt, Spliterator.OfLong, Spliterator.OfPrimitive<T,T_CONS,T_SPLITR>

Field Summary

Fields

Modifier and Type	Field	Description
private R	acc
private final BiFunction<R,T,R>	accumulator
private final BinaryOperator<R>	combiner
(package private) CollapseSpliterator.Connector<T,R>	left
private final Function<T,R>	mapper
private final BiPredicate<? super T, ? super T>	mergeable
(package private) CollapseSpliterator.Connector<T,R>	right
private final CollapseSpliterator<T,R>	root
private final Spliterator<T>	source

Fields inherited from class Internals.Box

a

Fields inherited from interface Spliterator

CONCURRENT, DISTINCT, IMMUTABLE, NONNULL, ORDERED, SIZED, SORTED, SUBSIZED

Constructor Summary

Constructors

Modifier	Constructor	Description
(package private)	CollapseSpliterator(BiPredicate<? super T, ? super T> mergeable, Function<T,R> mapper, BiFunction<R,T,R> accumulator, BinaryOperator<R> combiner, Spliterator<T> source)
private	CollapseSpliterator(CollapseSpliterator<T,R> root, Spliterator<T> source, CollapseSpliterator.Connector<T,R> left, CollapseSpliterator.Connector<T,R> right)

Method Summary

Modifier and Type	Method	Description
private boolean	accept(R acc, Consumer<? super R> action)
int	characteristics()
private R	connectEmpty()
private R	connectOne(T first, R acc, T last)
long	estimateSize()
void	forEachRemaining(Consumer<? super R> action)
private R	handleLeft()
private R	pushLeft(T first, R acc)
private R	pushRight(R acc, T last)
boolean	tryAdvance(Consumer<? super R> action)
Spliterator<R>	trySplit()

Methods inherited from class Internals.Box

accept, asOptional, partialCollector

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface Consumer

andThen

Methods inherited from interface Spliterator

getComparator, getExactSizeIfKnown, hasCharacteristics

Field Details

source

private final Spliterator<T> source

root

private final CollapseSpliterator<T,R> root

acc

private R acc

left

volatile CollapseSpliterator.Connector<T,R> left

right

volatile CollapseSpliterator.Connector<T,R> right

mapper

private final Function<T,R> mapper

accumulator

private final BiFunction<R,T,R> accumulator

combiner

private final BinaryOperator<R> combiner

mergeable

private final BiPredicate<? super T, ? super T> mergeable

Constructor Details

CollapseSpliterator

CollapseSpliterator(BiPredicate<? super T, ? super T> mergeable,
 Function<T,R> mapper,
 BiFunction<R,T,R> accumulator,
 BinaryOperator<R> combiner,
 Spliterator<T> source)

CollapseSpliterator

private CollapseSpliterator(CollapseSpliterator<T,R> root,
 Spliterator<T> source,
 CollapseSpliterator.Connector<T,R> left,
 CollapseSpliterator.Connector<T,R> right)

Method Details

tryAdvance

public boolean tryAdvance(Consumer<? super R> action)

Specified by:

tryAdvance in interface Spliterator<T>

forEachRemaining

public void forEachRemaining(Consumer<? super R> action)

Specified by:

forEachRemaining in interface Spliterator<T>

accept

private boolean accept(R acc,
 Consumer<? super R> action)

handleLeft

private R handleLeft()

pushLeft

private R pushLeft(T first,
 R acc)

pushRight

private R pushRight(R acc,
 T last)

connectOne

private R connectOne(T first,
 R acc,
 T last)

connectEmpty

private R connectEmpty()

trySplit

public Spliterator<R> trySplit()

Specified by:

trySplit in interface Spliterator<T>

estimateSize

public long estimateSize()

Specified by:

estimateSize in interface Spliterator<T>

characteristics

public int characteristics()

Specified by:

characteristics in interface Spliterator<T>