Package io.avery.vinyl

Class RecordStream.AuxInt

java.lang.Object

io.avery.vinyl.RecordStream.AuxInt

All Implemented Interfaces:

AutoCloseable, BaseStream<Integer,IntStream>, IntStream

Enclosing class:

RecordStream

public static class RecordStream.AuxInt
extends Object
implements IntStream

An auxiliary stream of ints that may readily be converted to or from a record-stream.

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.stream.IntStream

IntStream.Builder

Method Summary

Modifier and Type	Method	Description
boolean	allMatch(IntPredicate predicate)
boolean	anyMatch(IntPredicate predicate)
RecordStream.AuxDouble	asDoubleStream()
RecordStream.AuxLong	asLongStream()
OptionalDouble	average()
RecordStream.Aux<Integer>	boxed()
void	close()
<R> R	collect(Supplier<R> supplier, ObjIntConsumer<R> accumulator, BiConsumer<R,R> combiner)
long	count()
RecordStream.AuxInt	distinct()
RecordStream.AuxInt	dropWhile(IntPredicate predicate)
RecordStream.AuxInt	filter(IntPredicate predicate)
OptionalInt	findAny()
OptionalInt	findFirst()
RecordStream.AuxInt	flatMap(IntFunction<? extends IntStream> mapper)
void	forEach(IntConsumer action)
void	forEachOrdered(IntConsumer action)
boolean	isParallel()
PrimitiveIterator.OfInt	iterator()
RecordStream.AuxInt	limit(long maxSize)
RecordStream.AuxInt	map(IntUnaryOperator mapper)
RecordStream.AuxDouble	mapToDouble(IntToDoubleFunction mapper)
RecordStream.AuxLong	mapToLong(IntToLongFunction mapper)
<U> RecordStream.Aux<U>	mapToObj(IntFunction<? extends U> mapper)
OptionalInt	max()
OptionalInt	min()
boolean	noneMatch(IntPredicate predicate)
RecordStream.AuxInt	onClose(Runnable closeHandler)
RecordStream.AuxInt	parallel()
RecordStream.AuxInt	peek(IntConsumer action)
int	reduce(int identity, IntBinaryOperator op)
OptionalInt	reduce(IntBinaryOperator op)
RecordStream.AuxInt	sequential()
RecordStream.AuxInt	skip(long n)
RecordStream.AuxInt	sorted()
Spliterator.OfInt	spliterator()
int	sum()
IntSummaryStatistics	summaryStatistics()
RecordStream.AuxInt	takeWhile(IntPredicate predicate)
int[]	toArray()
RecordStream.AuxInt	unordered()

Methods inherited from class java.lang.Object

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

Method Details

takeWhile

public RecordStream.AuxInt takeWhile(IntPredicate predicate)

Specified by:

takeWhile in interface IntStream

dropWhile

public RecordStream.AuxInt dropWhile(IntPredicate predicate)

Specified by:

dropWhile in interface IntStream

filter

public RecordStream.AuxInt filter(IntPredicate predicate)

Specified by:

filter in interface IntStream

map

public RecordStream.AuxInt map(IntUnaryOperator mapper)

Specified by:

map in interface IntStream

mapToObj

public <U> RecordStream.Aux<U> mapToObj(IntFunction<? extends U> mapper)

Specified by:

mapToObj in interface IntStream

mapToLong

public RecordStream.AuxLong mapToLong(IntToLongFunction mapper)

Specified by:

mapToLong in interface IntStream

mapToDouble

public RecordStream.AuxDouble mapToDouble(IntToDoubleFunction mapper)

Specified by:

mapToDouble in interface IntStream

flatMap

public RecordStream.AuxInt flatMap(IntFunction<? extends IntStream> mapper)

Specified by:

flatMap in interface IntStream

distinct

public RecordStream.AuxInt distinct()

Specified by:

distinct in interface IntStream

sorted

public RecordStream.AuxInt sorted()

Specified by:

sorted in interface IntStream

peek

public RecordStream.AuxInt peek(IntConsumer action)

Specified by:

peek in interface IntStream

limit

public RecordStream.AuxInt limit(long maxSize)

Specified by:

limit in interface IntStream

skip

public RecordStream.AuxInt skip(long n)

Specified by:

skip in interface IntStream

forEach

public void forEach(IntConsumer action)

Specified by:

forEach in interface IntStream

forEachOrdered

public void forEachOrdered(IntConsumer action)

Specified by:

forEachOrdered in interface IntStream

toArray

public int[] toArray()

Specified by:

toArray in interface IntStream

reduce

public int reduce(int identity,
 IntBinaryOperator op)

Specified by:

reduce in interface IntStream

reduce

public OptionalInt reduce(IntBinaryOperator op)

Specified by:

reduce in interface IntStream

collect

public <R> R collect(Supplier<R> supplier,
 ObjIntConsumer<R> accumulator,
 BiConsumer<R,R> combiner)

Specified by:

collect in interface IntStream

sum

public int sum()

Specified by:

sum in interface IntStream

min

public OptionalInt min()

Specified by:

min in interface IntStream

max

public OptionalInt max()

Specified by:

max in interface IntStream

count

public long count()

Specified by:

count in interface IntStream

average

public OptionalDouble average()

Specified by:

average in interface IntStream

summaryStatistics

public IntSummaryStatistics summaryStatistics()

Specified by:

summaryStatistics in interface IntStream

anyMatch

public boolean anyMatch(IntPredicate predicate)

Specified by:

anyMatch in interface IntStream

allMatch

public boolean allMatch(IntPredicate predicate)

Specified by:

allMatch in interface IntStream

noneMatch

public boolean noneMatch(IntPredicate predicate)

Specified by:

noneMatch in interface IntStream

findFirst

public OptionalInt findFirst()

Specified by:

findFirst in interface IntStream

findAny

public OptionalInt findAny()

Specified by:

findAny in interface IntStream

asLongStream

public RecordStream.AuxLong asLongStream()

Specified by:

asLongStream in interface IntStream

asDoubleStream

public RecordStream.AuxDouble asDoubleStream()

Specified by:

asDoubleStream in interface IntStream

boxed

public RecordStream.Aux<Integer> boxed()

Specified by:

boxed in interface IntStream

sequential

public RecordStream.AuxInt sequential()

Specified by:

sequential in interface BaseStream<Integer,IntStream>

Specified by:

sequential in interface IntStream

parallel

public RecordStream.AuxInt parallel()

Specified by:

parallel in interface BaseStream<Integer,IntStream>

Specified by:

parallel in interface IntStream

unordered

public RecordStream.AuxInt unordered()

Specified by:

unordered in interface BaseStream<Integer,IntStream>

onClose

public RecordStream.AuxInt onClose(Runnable closeHandler)

Specified by:

onClose in interface BaseStream<Integer,IntStream>

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface BaseStream<Integer,IntStream>

iterator

public PrimitiveIterator.OfInt iterator()

Specified by:

iterator in interface BaseStream<Integer,IntStream>

Specified by:

iterator in interface IntStream

spliterator

public Spliterator.OfInt spliterator()

Specified by:

spliterator in interface BaseStream<Integer,IntStream>

Specified by:

spliterator in interface IntStream

isParallel

public boolean isParallel()

Specified by:

isParallel in interface BaseStream<Integer,IntStream>