Class EmitterSpliterator<T>

java.lang.Object

java.util.Spliterators.AbstractSpliterator<T>

one.util.streamex.EmitterSpliterator<T>

All Implemented Interfaces:

Consumer<T>, Spliterator<T>

final class EmitterSpliterator<T>
extends Spliterators.AbstractSpliterator<T>
implements Consumer<T>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	EmitterSpliterator.OfDouble
(package private) static final class	EmitterSpliterator.OfInt
(package private) static final class	EmitterSpliterator.OfLong

Nested classes/interfaces inherited from interface Spliterator

Spliterator.OfPrimitive<T,T_CONS,T_SPLITR>

Field Summary

Fields

Modifier and Type	Field	Description
private Spliterator<T>	buf
private Consumer<? super T>	cons
(package private) StreamEx.Emitter<T>	e
private int	vals

Fields inherited from interface Spliterator

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

Constructor Summary

Constructors

Constructor	Description
EmitterSpliterator(StreamEx.Emitter<T> e)

Method Summary

Modifier and Type	Method	Description
void	accept(T t)
void	forEachRemaining(Consumer<? super T> action)
boolean	tryAdvance(Consumer<? super T> action)

Methods inherited from class Spliterators.AbstractSpliterator

characteristics, estimateSize, trySplit

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

e

StreamEx.Emitter<T> e

buf

private Spliterator<T> buf

vals

private int vals

cons

private Consumer<? super T> cons

Constructor Details

EmitterSpliterator

EmitterSpliterator(StreamEx.Emitter<T> e)

Method Details

tryAdvance

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

Specified by:

tryAdvance in interface Spliterator<T>

forEachRemaining

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

Specified by:

forEachRemaining in interface Spliterator<T>

accept

public void accept(T t)

Specified by:

accept in interface Consumer<T>