Class WithFirstSpliterator<T,R>

java.lang.Object

one.util.streamex.Internals.CloneableSpliterator<R, WithFirstSpliterator<T,R>>

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

All Implemented Interfaces:

Cloneable, Consumer<T>, Spliterator<R>

final class WithFirstSpliterator<T,R>
extends Internals.CloneableSpliterator<R, WithFirstSpliterator<T,R>>
implements Consumer<T>

Nested Class Summary

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 Consumer<? super R>	action
private T	first
private ReentrantLock	lock
private final BiFunction<? super T, ? super T, ? extends R>	mapper
private WithFirstSpliterator<T,R>	prefix
private Spliterator<T>	source
private int	state
private static final int	STATE_EMPTY
private static final int	STATE_FIRST_READ
private static final int	STATE_INIT
private static final int	STATE_NONE

Fields inherited from interface Spliterator

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

Constructor Summary

Constructors

Constructor	Description
WithFirstSpliterator(Spliterator<T> source, BiFunction<? super T, ? super T, ? extends R> mapper)

Method Summary

Modifier and Type	Method	Description
void	accept(T x)
private void	acquire()
int	characteristics()
private void	doInit()
long	estimateSize()
void	forEachRemaining(Consumer<? super R> action)
private void	release()
boolean	tryAdvance(Consumer<? super R> action)
Spliterator<R>	trySplit()

Methods inherited from class Internals.CloneableSpliterator

doClone

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

STATE_NONE

private static final int STATE_NONE

See Also:

• Constant Field Values

STATE_FIRST_READ

private static final int STATE_FIRST_READ

See Also:

• Constant Field Values

STATE_INIT

private static final int STATE_INIT

See Also:

• Constant Field Values

STATE_EMPTY

private static final int STATE_EMPTY

See Also:

• Constant Field Values

lock

private ReentrantLock lock

source

private Spliterator<T> source

prefix

private WithFirstSpliterator<T,R> prefix

first

private volatile T first

state

private volatile int state

mapper

private final BiFunction<? super T, ? super T, ? extends R> mapper

action

private Consumer<? super R> action

Constructor Details

WithFirstSpliterator

WithFirstSpliterator(Spliterator<T> source,
 BiFunction<? super T, ? super T, ? extends R> mapper)

Method Details

acquire

private void acquire()

release

private void release()

tryAdvance

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

Specified by:

tryAdvance in interface Spliterator<T>

doInit

private void doInit()

forEachRemaining

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

Specified by:

forEachRemaining in interface Spliterator<T>

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>

accept

public void accept(T x)

Specified by:

accept in interface Consumer<T>