Package com.terracottatech.store.async

Interface AsyncDoubleStream

All Superinterfaces:

AutoCloseable, BaseStream<Double,AsyncDoubleStream>

public interface AsyncDoubleStream
extends BaseStream<Double,AsyncDoubleStream>

An asynchronous equivalent to DoubleStream.

See Also:

• DoubleStream

Method Summary

Modifier and Type	Method	Description
Operation<Boolean>	allMatch(DoublePredicate predicate)	An asynchronous equivalent to DoubleStream.allMatch(java.util.function.DoublePredicate).
Operation<Boolean>	anyMatch(DoublePredicate predicate)	An asynchronous equivalent to DoubleStream.anyMatch(java.util.function.DoublePredicate).
Operation<OptionalDouble>	average()	An asynchronous equivalent to DoubleStream.average().
AsyncStream<Double>	boxed()	An asynchronous equivalent to DoubleStream.boxed().
<R> Operation<R>	collect(Supplier<R> supplier, ObjDoubleConsumer<R> accumulator, BiConsumer<R,R> combiner)	An asynchronous equivalent to DoubleStream.collect(java.util.function.Supplier, java.util.function.ObjDoubleConsumer, java.util.function.BiConsumer).
Operation<Long>	count()	An asynchronous equivalent to DoubleStream.count().
AsyncDoubleStream	distinct()	An asynchronous equivalent to DoubleStream.distinct().
AsyncDoubleStream	filter(DoublePredicate predicate)	An asynchronous equivalent to DoubleStream.filter(java.util.function.DoublePredicate).
Operation<OptionalDouble>	findAny()	An asynchronous equivalent to DoubleStream.findAny().
Operation<OptionalDouble>	findFirst()	An asynchronous equivalent to DoubleStream.findFirst().
AsyncDoubleStream	flatMap(DoubleFunction<? extends DoubleStream> mapper)	An asynchronous equivalent to DoubleStream.flatMap(java.util.function.DoubleFunction).
Operation<Void>	forEach(DoubleConsumer action)	An asynchronous equivalent to DoubleStream.forEach(java.util.function.DoubleConsumer).
Operation<Void>	forEachOrdered(DoubleConsumer action)	An asynchronous equivalent to DoubleStream.forEachOrdered(java.util.function.DoubleConsumer).
PrimitiveIterator.OfDouble	iterator()
AsyncDoubleStream	limit(long maxSize)	An asynchronous equivalent to DoubleStream.limit(long).
AsyncDoubleStream	map(DoubleUnaryOperator mapper)	An asynchronous equivalent to DoubleStream.map(java.util.function.DoubleUnaryOperator).
AsyncIntStream	mapToInt(DoubleToIntFunction mapper)	An asynchronous equivalent to DoubleStream.mapToInt(java.util.function.DoubleToIntFunction).
AsyncLongStream	mapToLong(DoubleToLongFunction mapper)	An asynchronous equivalent to DoubleStream.mapToLong(java.util.function.DoubleToLongFunction).
<U> AsyncStream<U>	mapToObj(DoubleFunction<? extends U> mapper)	An asynchronous equivalent to DoubleStream.mapToObj(java.util.function.DoubleFunction).
Operation<OptionalDouble>	max()	An asynchronous equivalent to DoubleStream.max().
Operation<OptionalDouble>	min()	An asynchronous equivalent to DoubleStream.min().
Operation<Boolean>	noneMatch(DoublePredicate predicate)	An asynchronous equivalent to DoubleStream.noneMatch(java.util.function.DoublePredicate).
AsyncDoubleStream	parallel()
AsyncDoubleStream	peek(DoubleConsumer action)	An asynchronous equivalent to DoubleStream.peek(java.util.function.DoubleConsumer).
Operation<Double>	reduce(double identity, DoubleBinaryOperator op)	An asynchronous equivalent to DoubleStream.reduce(double, java.util.function.DoubleBinaryOperator).
Operation<OptionalDouble>	reduce(DoubleBinaryOperator op)	An asynchronous equivalent to DoubleStream.reduce(java.util.function.DoubleBinaryOperator).
AsyncDoubleStream	sequential()
AsyncDoubleStream	skip(long n)	An asynchronous equivalent to DoubleStream.skip(long).
AsyncDoubleStream	sorted()	An asynchronous equivalent to DoubleStream.sorted().
Spliterator.OfDouble	spliterator()
Operation<Double>	sum()	An asynchronous equivalent to DoubleStream.sum().
Operation<DoubleSummaryStatistics>	summaryStatistics()	An asynchronous equivalent to DoubleStream.summaryStatistics().
Operation<double[]>	toArray()	An asynchronous equivalent to DoubleStream.toArray().

Methods inherited from interface java.util.stream.BaseStream

close, isParallel, onClose, unordered

Method Details

filter

AsyncDoubleStream filter(DoublePredicate predicate)

An asynchronous equivalent to DoubleStream.filter(java.util.function.DoublePredicate).

Parameters:

predicate - the inclusion predicate

Returns:

the new stream

map

AsyncDoubleStream map(DoubleUnaryOperator mapper)

An asynchronous equivalent to DoubleStream.map(java.util.function.DoubleUnaryOperator).

Parameters:

mapper - the element mapping function

Returns:

the new stream

mapToObj

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

An asynchronous equivalent to DoubleStream.mapToObj(java.util.function.DoubleFunction).

Type Parameters:

U - the element type of the new stream

Parameters:

mapper - the element mapping function

Returns:

the new stream

mapToInt

AsyncIntStream mapToInt(DoubleToIntFunction mapper)

An asynchronous equivalent to DoubleStream.mapToInt(java.util.function.DoubleToIntFunction).

Parameters:

mapper - the element mapping function

Returns:

the new stream

mapToLong

AsyncLongStream mapToLong(DoubleToLongFunction mapper)

An asynchronous equivalent to DoubleStream.mapToLong(java.util.function.DoubleToLongFunction).

Parameters:

mapper - the element mapping function

Returns:

the new stream

flatMap

AsyncDoubleStream flatMap(DoubleFunction<? extends DoubleStream> mapper)

An asynchronous equivalent to DoubleStream.flatMap(java.util.function.DoubleFunction).

Parameters:

mapper - the element mapping function

Returns:

the new stream

distinct

AsyncDoubleStream distinct()

An asynchronous equivalent to DoubleStream.distinct().

Returns:

the new stream

sorted

AsyncDoubleStream sorted()

An asynchronous equivalent to DoubleStream.sorted().

Returns:

the new stream

peek

AsyncDoubleStream peek(DoubleConsumer action)

An asynchronous equivalent to DoubleStream.peek(java.util.function.DoubleConsumer).

Parameters:

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

Returns:

the new stream

limit

AsyncDoubleStream limit(long maxSize)

An asynchronous equivalent to DoubleStream.limit(long).

Parameters:

maxSize - maximum number of elements

Returns:

the new stream

skip

AsyncDoubleStream skip(long n)

An asynchronous equivalent to DoubleStream.skip(long).

Parameters:

n - number of leading elements to skip

Returns:

the new stream

forEach

Operation<Void> forEach(DoubleConsumer action)

An asynchronous equivalent to DoubleStream.forEach(java.util.function.DoubleConsumer).

Parameters:

action - action to perform on the elements

Returns:

an Operation representing the completion of this action across all elements

forEachOrdered

Operation<Void> forEachOrdered(DoubleConsumer action)

An asynchronous equivalent to DoubleStream.forEachOrdered(java.util.function.DoubleConsumer).

Parameters:

action - action to perform on the elements

Returns:

an Operation representing the completion of this action across all elements

toArray

Operation<double[]> toArray()

An asynchronous equivalent to DoubleStream.toArray().

Returns:

an Operation representing the conversion of this stream to an array

reduce

Operation<Double> reduce(double identity,
 DoubleBinaryOperator op)

An asynchronous equivalent to DoubleStream.reduce(double, java.util.function.DoubleBinaryOperator).

Parameters:

identity - identity value of the accumulating operator

op - the accumulating operator

Returns:

an Operation representing the execution of this reduction

reduce

Operation<OptionalDouble> reduce(DoubleBinaryOperator op)

An asynchronous equivalent to DoubleStream.reduce(java.util.function.DoubleBinaryOperator).

Parameters:

op - the accumulating operator

Returns:

an Operation representing the execution of this reduction

collect

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

An asynchronous equivalent to DoubleStream.collect(java.util.function.Supplier, java.util.function.ObjDoubleConsumer, 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<Double> sum()

An asynchronous equivalent to DoubleStream.sum().

Returns:

an Operation representing the sum of all elements

min

Operation<OptionalDouble> min()

An asynchronous equivalent to DoubleStream.min().

Returns:

an Operation representing the calculation of the minimum value

max

Operation<OptionalDouble> max()

An asynchronous equivalent to DoubleStream.max().

Returns:

an Operation representing the calculation of the maximum value

count

Operation<Long> count()

An asynchronous equivalent to DoubleStream.count().

Returns:

an Operation representing the length of the stream

average

Operation<OptionalDouble> average()

An asynchronous equivalent to DoubleStream.average().

Returns:

an Operation representing the calculation of the average of all elements

summaryStatistics

Operation<DoubleSummaryStatistics> summaryStatistics()

An asynchronous equivalent to DoubleStream.summaryStatistics().

Returns:

an Operation representing the calculation of statistics for this stream.

anyMatch

Operation<Boolean> anyMatch(DoublePredicate predicate)

An asynchronous equivalent to DoubleStream.anyMatch(java.util.function.DoublePredicate).

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

An asynchronous equivalent to DoubleStream.allMatch(java.util.function.DoublePredicate).

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

An asynchronous equivalent to DoubleStream.noneMatch(java.util.function.DoublePredicate).

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

An asynchronous equivalent to DoubleStream.findFirst().

Returns:

an Operation returning the first element of the stream

findAny

Operation<OptionalDouble> findAny()

An asynchronous equivalent to DoubleStream.findAny().

Returns:

an Operation returning an element of the stream

boxed

AsyncStream<Double> boxed()

An asynchronous equivalent to DoubleStream.boxed().

Returns:

an AsyncStream containing boxed versions of this streams values

sequential

AsyncDoubleStream sequential()

Specified by:

sequential in interface BaseStream<Double,AsyncDoubleStream>

parallel

AsyncDoubleStream parallel()

Specified by:

parallel in interface BaseStream<Double,AsyncDoubleStream>

iterator

PrimitiveIterator.OfDouble iterator()

Specified by:

iterator in interface BaseStream<Double,AsyncDoubleStream>

spliterator

Spliterator.OfDouble spliterator()

Specified by:

spliterator in interface BaseStream<Double,AsyncDoubleStream>