Package com.terracottatech.store.async

Interface AsyncLongStream

All Superinterfaces:

AutoCloseable, BaseStream<Long,AsyncLongStream>

public interface AsyncLongStream
extends BaseStream<Long,AsyncLongStream>

An asynchronous equivalent to LongStream.

See Also:

• LongStream

Method Summary

Modifier and Type	Method	Description
Operation<Boolean>	allMatch(LongPredicate predicate)	An asynchronous equivalent to LongStream.allMatch(java.util.function.LongPredicate).
Operation<Boolean>	anyMatch(LongPredicate predicate)	An asynchronous equivalent to LongStream.anyMatch(java.util.function.LongPredicate).
AsyncDoubleStream	asDoubleStream()	An asynchronous equivalent to LongStream.asDoubleStream().
Operation<OptionalDouble>	average()	An asynchronous equivalent to LongStream.average().
AsyncStream<Long>	boxed()	An asynchronous equivalent to LongStream.boxed().
<R> Operation<R>	collect(Supplier<R> supplier, ObjLongConsumer<R> accumulator, BiConsumer<R,R> combiner)	An asynchronous equivalent to LongStream.collect(java.util.function.Supplier, java.util.function.ObjLongConsumer, java.util.function.BiConsumer).
Operation<Long>	count()	An asynchronous equivalent to LongStream.count().
AsyncLongStream	distinct()	An asynchronous equivalent to LongStream.distinct().
AsyncLongStream	filter(LongPredicate predicate)	An asynchronous equivalent to LongStream.filter(java.util.function.LongPredicate).
Operation<OptionalLong>	findAny()	An asynchronous equivalent to LongStream.findAny().
Operation<OptionalLong>	findFirst()	An asynchronous equivalent to LongStream.findFirst().
AsyncLongStream	flatMap(LongFunction<? extends LongStream> mapper)	An asynchronous equivalent to LongStream.flatMap(java.util.function.LongFunction).
Operation<Void>	forEach(LongConsumer action)	An asynchronous equivalent to LongStream.forEach(java.util.function.LongConsumer).
Operation<Void>	forEachOrdered(LongConsumer action)	An asynchronous equivalent to LongStream.forEachOrdered(java.util.function.LongConsumer).
PrimitiveIterator.OfLong	iterator()
AsyncLongStream	limit(long maxSize)	An asynchronous equivalent to LongStream.limit(long).
AsyncLongStream	map(LongUnaryOperator mapper)	An asynchronous equivalent to LongStream.map(java.util.function.LongUnaryOperator).
AsyncDoubleStream	mapToDouble(LongToDoubleFunction mapper)	An asynchronous equivalent to LongStream.mapToDouble(java.util.function.LongToDoubleFunction).
AsyncIntStream	mapToInt(LongToIntFunction mapper)	An asynchronous equivalent to LongStream.mapToInt(java.util.function.LongToIntFunction).
<U> AsyncStream<U>	mapToObj(LongFunction<? extends U> mapper)	An asynchronous equivalent to LongStream.mapToObj(java.util.function.LongFunction).
Operation<OptionalLong>	max()	An asynchronous equivalent to LongStream.max().
Operation<OptionalLong>	min()	An asynchronous equivalent to LongStream.min().
Operation<Boolean>	noneMatch(LongPredicate predicate)	An asynchronous equivalent to LongStream.noneMatch(java.util.function.LongPredicate).
AsyncLongStream	parallel()
AsyncLongStream	peek(LongConsumer action)	An asynchronous equivalent to LongStream.peek(java.util.function.LongConsumer).
Operation<Long>	reduce(long identity, LongBinaryOperator op)	An asynchronous equivalent to LongStream.reduce(long, java.util.function.LongBinaryOperator).
Operation<OptionalLong>	reduce(LongBinaryOperator op)	An asynchronous equivalent to LongStream.reduce(java.util.function.LongBinaryOperator).
AsyncLongStream	sequential()
AsyncLongStream	skip(long n)	An asynchronous equivalent to LongStream.skip(long).
AsyncLongStream	sorted()	An asynchronous equivalent to LongStream.sorted().
Spliterator.OfLong	spliterator()
Operation<Long>	sum()	An asynchronous equivalent to LongStream.sum().
Operation<LongSummaryStatistics>	summaryStatistics()	An asynchronous equivalent to LongStream.summaryStatistics().
Operation<long[]>	toArray()	An asynchronous equivalent to LongStream.toArray().

Methods inherited from interface java.util.stream.BaseStream

close, isParallel, onClose, unordered

Method Details

filter

AsyncLongStream filter(LongPredicate predicate)

An asynchronous equivalent to LongStream.filter(java.util.function.LongPredicate).

Parameters:

predicate - the inclusion predicate

Returns:

the new stream

map

AsyncLongStream map(LongUnaryOperator mapper)

An asynchronous equivalent to LongStream.map(java.util.function.LongUnaryOperator).

Parameters:

mapper - the element mapping function

Returns:

the new stream

mapToObj

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

An asynchronous equivalent to LongStream.mapToObj(java.util.function.LongFunction).

Type Parameters:

U - the element type of the new stream

Parameters:

mapper - the element mapping function

Returns:

the new stream

mapToInt

AsyncIntStream mapToInt(LongToIntFunction mapper)

An asynchronous equivalent to LongStream.mapToInt(java.util.function.LongToIntFunction).

Parameters:

mapper - the element mapping function

Returns:

the new stream

mapToDouble

AsyncDoubleStream mapToDouble(LongToDoubleFunction mapper)

An asynchronous equivalent to LongStream.mapToDouble(java.util.function.LongToDoubleFunction).

Parameters:

mapper - the element mapping function

Returns:

the new stream

flatMap

AsyncLongStream flatMap(LongFunction<? extends LongStream> mapper)

An asynchronous equivalent to LongStream.flatMap(java.util.function.LongFunction).

Parameters:

mapper - the element mapping function

Returns:

the new stream

distinct

AsyncLongStream distinct()

An asynchronous equivalent to LongStream.distinct().

Returns:

the new stream

sorted

AsyncLongStream sorted()

An asynchronous equivalent to LongStream.sorted().

Returns:

the new stream

peek

AsyncLongStream peek(LongConsumer action)

An asynchronous equivalent to LongStream.peek(java.util.function.LongConsumer).

Parameters:

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

Returns:

the new stream

limit

AsyncLongStream limit(long maxSize)

An asynchronous equivalent to LongStream.limit(long).

Parameters:

maxSize - maximum number of elements

Returns:

the new stream

skip

AsyncLongStream skip(long n)

An asynchronous equivalent to LongStream.skip(long).

Parameters:

n - number of leading elements to skip

Returns:

the new stream

forEach

Operation<Void> forEach(LongConsumer action)

An asynchronous equivalent to LongStream.forEach(java.util.function.LongConsumer).

Parameters:

action - action to perform on the elements

Returns:

an Operation representing the completion of this action across all elements

forEachOrdered

Operation<Void> forEachOrdered(LongConsumer action)

An asynchronous equivalent to LongStream.forEachOrdered(java.util.function.LongConsumer).

Parameters:

action - action to perform on the elements

Returns:

an Operation representing the completion of this action across all elements

toArray

Operation<long[]> toArray()

An asynchronous equivalent to LongStream.toArray().

Returns:

an Operation representing the conversion of this stream to an array

reduce

Operation<Long> reduce(long identity,
 LongBinaryOperator op)

An asynchronous equivalent to LongStream.reduce(long, java.util.function.LongBinaryOperator).

Parameters:

identity - identity value of the accumulating operator

op - the accumulating operator

Returns:

an Operation representing the execution of this reduction

reduce

Operation<OptionalLong> reduce(LongBinaryOperator op)

An asynchronous equivalent to LongStream.reduce(java.util.function.LongBinaryOperator).

Parameters:

op - the accumulating operator

Returns:

an Operation representing the execution of this reduction

collect

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

An asynchronous equivalent to LongStream.collect(java.util.function.Supplier, java.util.function.ObjLongConsumer, 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<Long> sum()

An asynchronous equivalent to LongStream.sum().

Returns:

an Operation representing the sum of all elements

min

Operation<OptionalLong> min()

An asynchronous equivalent to LongStream.min().

Returns:

an Operation representing the calculation of the minimum value

max

Operation<OptionalLong> max()

An asynchronous equivalent to LongStream.max().

Returns:

an Operation representing the calculation of the maximum value

count

Operation<Long> count()

An asynchronous equivalent to LongStream.count().

Returns:

an Operation representing the length of the stream

average

Operation<OptionalDouble> average()

An asynchronous equivalent to LongStream.average().

Returns:

an Operation representing the calculation of the average of all elements

summaryStatistics

Operation<LongSummaryStatistics> summaryStatistics()

An asynchronous equivalent to LongStream.summaryStatistics().

Returns:

an Operation representing the calculation of statistics for this stream.

anyMatch

Operation<Boolean> anyMatch(LongPredicate predicate)

An asynchronous equivalent to LongStream.anyMatch(java.util.function.LongPredicate).

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(LongPredicate predicate)

An asynchronous equivalent to LongStream.allMatch(java.util.function.LongPredicate).

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(LongPredicate predicate)

An asynchronous equivalent to LongStream.noneMatch(java.util.function.LongPredicate).

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<OptionalLong> findFirst()

An asynchronous equivalent to LongStream.findFirst().

Returns:

an Operation returning the first element of the stream

findAny

Operation<OptionalLong> findAny()

An asynchronous equivalent to LongStream.findAny().

Returns:

an Operation returning an element of the stream

asDoubleStream

AsyncDoubleStream asDoubleStream()

An asynchronous equivalent to LongStream.asDoubleStream().

Returns:

an AsyncDoubleStream containing these values converted to doubles

boxed

AsyncStream<Long> boxed()

An asynchronous equivalent to LongStream.boxed().

Returns:

an AsyncStream containing boxed versions of this streams values

sequential

AsyncLongStream sequential()

Specified by:

sequential in interface BaseStream<Long,AsyncLongStream>

parallel

AsyncLongStream parallel()

Specified by:

parallel in interface BaseStream<Long,AsyncLongStream>

iterator

PrimitiveIterator.OfLong iterator()

Specified by:

iterator in interface BaseStream<Long,AsyncLongStream>

spliterator

Spliterator.OfLong spliterator()

Specified by:

spliterator in interface BaseStream<Long,AsyncLongStream>