Package com.terracottatech.store.async

Interface AsyncIntStream

All Superinterfaces:

AutoCloseable, BaseStream<Integer,AsyncIntStream>

public interface AsyncIntStream
extends BaseStream<Integer,AsyncIntStream>

An asynchronous equivalent to IntStream.

See Also:

• IntStream

Method Summary

Modifier and Type	Method	Description
Operation<Boolean>	allMatch(IntPredicate predicate)	An asynchronous equivalent to IntStream.allMatch(java.util.function.IntPredicate).
Operation<Boolean>	anyMatch(IntPredicate predicate)	An asynchronous equivalent to IntStream.anyMatch(java.util.function.IntPredicate).
AsyncDoubleStream	asDoubleStream()	An asynchronous equivalent to IntStream.asDoubleStream().
AsyncLongStream	asLongStream()	An asynchronous equivalent to IntStream.asLongStream().
Operation<OptionalDouble>	average()	An asynchronous equivalent to IntStream.average().
AsyncStream<Integer>	boxed()	An asynchronous equivalent to IntStream.boxed().
<R> Operation<R>	collect(Supplier<R> supplier, ObjIntConsumer<R> accumulator, BiConsumer<R,R> combiner)	An asynchronous equivalent to IntStream.collect(java.util.function.Supplier, java.util.function.ObjIntConsumer, java.util.function.BiConsumer).
Operation<Long>	count()	An asynchronous equivalent to IntStream.count().
AsyncIntStream	distinct()	An asynchronous equivalent to IntStream.distinct().
AsyncIntStream	filter(IntPredicate predicate)	An asynchronous equivalent to IntStream.filter(java.util.function.IntPredicate).
Operation<OptionalInt>	findAny()	An asynchronous equivalent to IntStream.findAny().
Operation<OptionalInt>	findFirst()	An asynchronous equivalent to IntStream.findFirst().
AsyncIntStream	flatMap(IntFunction<? extends IntStream> mapper)	An asynchronous equivalent to IntStream.flatMap(java.util.function.IntFunction).
Operation<Void>	forEach(IntConsumer action)	An asynchronous equivalent to IntStream.forEach(java.util.function.IntConsumer).
Operation<Void>	forEachOrdered(IntConsumer action)	An asynchronous equivalent to IntStream.forEachOrdered(java.util.function.IntConsumer).
PrimitiveIterator.OfInt	iterator()
AsyncIntStream	limit(long maxSize)	An asynchronous equivalent to IntStream.limit(long).
AsyncIntStream	map(IntUnaryOperator mapper)	An asynchronous equivalent to IntStream.map(java.util.function.IntUnaryOperator).
AsyncDoubleStream	mapToDouble(IntToDoubleFunction mapper)	An asynchronous equivalent to IntStream.mapToDouble(java.util.function.IntToDoubleFunction).
AsyncLongStream	mapToLong(IntToLongFunction mapper)	An asynchronous equivalent to IntStream.mapToLong(java.util.function.IntToLongFunction).
<U> AsyncStream<U>	mapToObj(IntFunction<? extends U> mapper)	An asynchronous equivalent to IntStream.mapToObj(java.util.function.IntFunction).
Operation<OptionalInt>	max()	An asynchronous equivalent to IntStream.max().
Operation<OptionalInt>	min()	An asynchronous equivalent to IntStream.min().
Operation<Boolean>	noneMatch(IntPredicate predicate)	An asynchronous equivalent to IntStream.noneMatch(java.util.function.IntPredicate).
AsyncIntStream	parallel()
AsyncIntStream	peek(IntConsumer action)	An asynchronous equivalent to IntStream.peek(java.util.function.IntConsumer).
Operation<Integer>	reduce(int identity, IntBinaryOperator op)	An asynchronous equivalent to IntStream.reduce(int, java.util.function.IntBinaryOperator).
Operation<OptionalInt>	reduce(IntBinaryOperator op)	An asynchronous equivalent to IntStream.reduce(java.util.function.IntBinaryOperator).
AsyncIntStream	sequential()
AsyncIntStream	skip(long n)	An asynchronous equivalent to IntStream.skip(long).
AsyncIntStream	sorted()	An asynchronous equivalent to IntStream.sorted().
Spliterator.OfInt	spliterator()
Operation<Integer>	sum()	An asynchronous equivalent to IntStream.sum().
Operation<IntSummaryStatistics>	summaryStatistics()	An asynchronous equivalent to IntStream.summaryStatistics().
Operation<int[]>	toArray()	An asynchronous equivalent to IntStream.toArray().

Methods inherited from interface java.util.stream.BaseStream

close, isParallel, onClose, unordered

Method Details

filter

AsyncIntStream filter(IntPredicate predicate)

An asynchronous equivalent to IntStream.filter(java.util.function.IntPredicate).

Parameters:

predicate - the inclusion predicate

Returns:

the new stream

map

AsyncIntStream map(IntUnaryOperator mapper)

An asynchronous equivalent to IntStream.map(java.util.function.IntUnaryOperator).

Parameters:

mapper - the element mapping function

Returns:

the new stream

mapToObj

<U> AsyncStream<U> mapToObj(IntFunction<? extends U> mapper)

An asynchronous equivalent to IntStream.mapToObj(java.util.function.IntFunction).

Type Parameters:

U - the element type of the new stream

Parameters:

mapper - the element mapping function

Returns:

the new stream

mapToLong

AsyncLongStream mapToLong(IntToLongFunction mapper)

An asynchronous equivalent to IntStream.mapToLong(java.util.function.IntToLongFunction).

Parameters:

mapper - the element mapping function

Returns:

the new stream

mapToDouble

AsyncDoubleStream mapToDouble(IntToDoubleFunction mapper)

An asynchronous equivalent to IntStream.mapToDouble(java.util.function.IntToDoubleFunction).

Parameters:

mapper - the element mapping function

Returns:

the new stream

flatMap

AsyncIntStream flatMap(IntFunction<? extends IntStream> mapper)

An asynchronous equivalent to IntStream.flatMap(java.util.function.IntFunction).

Parameters:

mapper - the element mapping function

Returns:

the new stream

distinct

AsyncIntStream distinct()

An asynchronous equivalent to IntStream.distinct().

Returns:

the new stream

sorted

AsyncIntStream sorted()

An asynchronous equivalent to IntStream.sorted().

Returns:

the new stream

peek

AsyncIntStream peek(IntConsumer action)

An asynchronous equivalent to IntStream.peek(java.util.function.IntConsumer).

Parameters:

action - action to perform on the elements as they are consumed

Returns:

the new stream

limit

AsyncIntStream limit(long maxSize)

An asynchronous equivalent to IntStream.limit(long).

Parameters:

maxSize - maximum number of elements

Returns:

the new stream

skip

AsyncIntStream skip(long n)

An asynchronous equivalent to IntStream.skip(long).

Parameters:

n - number of leading elements to skip

Returns:

the new stream

forEach

Operation<Void> forEach(IntConsumer action)

An asynchronous equivalent to IntStream.forEach(java.util.function.IntConsumer).

Parameters:

action - action to perform on the elements

Returns:

an Operation representing the completion of this action across all elements

forEachOrdered

Operation<Void> forEachOrdered(IntConsumer action)

An asynchronous equivalent to IntStream.forEachOrdered(java.util.function.IntConsumer).

Parameters:

action - action to perform on the elements

Returns:

an Operation representing the completion of this action across all elements

toArray

Operation<int[]> toArray()

An asynchronous equivalent to IntStream.toArray().

Returns:

an Operation representing the conversion of this stream to an array

reduce

Operation<Integer> reduce(int identity,
 IntBinaryOperator op)

An asynchronous equivalent to IntStream.reduce(int, java.util.function.IntBinaryOperator).

Parameters:

identity - identity value of the accumulating operator

op - the accumulating operator

Returns:

an Operation representing the execution of this reduction

reduce

Operation<OptionalInt> reduce(IntBinaryOperator op)

An asynchronous equivalent to IntStream.reduce(java.util.function.IntBinaryOperator).

Parameters:

op - the accumulating operator

Returns:

an Operation representing the execution of this reduction

collect

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

An asynchronous equivalent to IntStream.collect(java.util.function.Supplier, java.util.function.ObjIntConsumer, java.util.function.BiConsumer).

Type Parameters:

R - the type of the result

Parameters:

supplier - the result container supplier

accumulator - the accumulating function

combiner - the combining function

Returns:

an Operation representing the execution of this reduction

sum

Operation<Integer> sum()

An asynchronous equivalent to IntStream.sum().

Returns:

an Operation representing the sum of all elements

min

Operation<OptionalInt> min()

An asynchronous equivalent to IntStream.min().

Returns:

an Operation representing the calculation of the minimum value

max

Operation<OptionalInt> max()

An asynchronous equivalent to IntStream.max().

Returns:

an Operation representing the calculation of the maximum value

count

Operation<Long> count()

An asynchronous equivalent to IntStream.count().

Returns:

an Operation representing the length of the stream

average

Operation<OptionalDouble> average()

An asynchronous equivalent to IntStream.average().

Returns:

an Operation representing the calculation of the average of all elements

summaryStatistics

Operation<IntSummaryStatistics> summaryStatistics()

An asynchronous equivalent to IntStream.summaryStatistics().

Returns:

an Operation representing the calculation of statistics for this stream.

anyMatch

Operation<Boolean> anyMatch(IntPredicate predicate)

An asynchronous equivalent to IntStream.anyMatch(java.util.function.IntPredicate).

Parameters:

predicate - predicate to apply to the elements in the stream

Returns:

an Operation returning true if at least one elements satisfies the predicate

allMatch

Operation<Boolean> allMatch(IntPredicate predicate)

An asynchronous equivalent to IntStream.allMatch(java.util.function.IntPredicate).

Parameters:

predicate - predicate to apply to the elements in the stream

Returns:

an Operation returning true if all the elements satisfy the predicate

noneMatch

Operation<Boolean> noneMatch(IntPredicate predicate)

An asynchronous equivalent to IntStream.noneMatch(java.util.function.IntPredicate).

Parameters:

predicate - predicate to apply to the elements in the stream

Returns:

an Operation returning true if none of the elements satisfy the predicate

findFirst

Operation<OptionalInt> findFirst()

An asynchronous equivalent to IntStream.findFirst().

Returns:

an Operation returning the first element of the stream

findAny

Operation<OptionalInt> findAny()

An asynchronous equivalent to IntStream.findAny().

Returns:

an Operation returning an element of the stream

asLongStream

AsyncLongStream asLongStream()

An asynchronous equivalent to IntStream.asLongStream().

Returns:

an AsyncLongStream containing these values converted to longs

asDoubleStream

AsyncDoubleStream asDoubleStream()

An asynchronous equivalent to IntStream.asDoubleStream().

Returns:

an AsyncDoubleStream containing these values converted to doubles

boxed

AsyncStream<Integer> boxed()

An asynchronous equivalent to IntStream.boxed().

Returns:

an AsyncStream containing boxed versions of this streams values

sequential

AsyncIntStream sequential()

Specified by:

sequential in interface BaseStream<Integer,AsyncIntStream>

parallel

AsyncIntStream parallel()

Specified by:

parallel in interface BaseStream<Integer,AsyncIntStream>

iterator

PrimitiveIterator.OfInt iterator()

Specified by:

iterator in interface BaseStream<Integer,AsyncIntStream>

spliterator

Spliterator.OfInt spliterator()

Specified by:

spliterator in interface BaseStream<Integer,AsyncIntStream>