public interface AsyncDoubleStream extends java.util.stream.BaseStream<java.lang.Double,AsyncDoubleStream>
DoubleStream
.DoubleStream
Modifier and Type | Method and Description |
---|---|
Operation<java.lang.Boolean> |
allMatch(java.util.function.DoublePredicate predicate)
An asynchronous equivalent to
DoubleStream.allMatch(java.util.function.DoublePredicate) . |
Operation<java.lang.Boolean> |
anyMatch(java.util.function.DoublePredicate predicate)
An asynchronous equivalent to
DoubleStream.anyMatch(java.util.function.DoublePredicate) . |
Operation<java.util.OptionalDouble> |
average()
An asynchronous equivalent to
DoubleStream.average() . |
AsyncStream<java.lang.Double> |
boxed()
An asynchronous equivalent to
DoubleStream.boxed() . |
<R> Operation<R> |
collect(java.util.function.Supplier<R> supplier,
java.util.function.ObjDoubleConsumer<R> accumulator,
java.util.function.BiConsumer<R,R> combiner)
An asynchronous equivalent to
DoubleStream.collect(java.util.function.Supplier, java.util.function.ObjDoubleConsumer, java.util.function.BiConsumer) . |
Operation<java.lang.Long> |
count()
An asynchronous equivalent to
DoubleStream.count() . |
AsyncDoubleStream |
distinct()
An asynchronous equivalent to
DoubleStream.distinct() . |
AsyncDoubleStream |
filter(java.util.function.DoublePredicate predicate)
An asynchronous equivalent to
DoubleStream.filter(java.util.function.DoublePredicate) . |
Operation<java.util.OptionalDouble> |
findAny()
An asynchronous equivalent to
DoubleStream.findAny() . |
Operation<java.util.OptionalDouble> |
findFirst()
An asynchronous equivalent to
DoubleStream.findFirst() . |
AsyncDoubleStream |
flatMap(java.util.function.DoubleFunction<? extends java.util.stream.DoubleStream> mapper)
An asynchronous equivalent to
DoubleStream.flatMap(java.util.function.DoubleFunction) . |
Operation<java.lang.Void> |
forEach(java.util.function.DoubleConsumer action)
An asynchronous equivalent to
DoubleStream.forEach(java.util.function.DoubleConsumer) . |
Operation<java.lang.Void> |
forEachOrdered(java.util.function.DoubleConsumer action)
An asynchronous equivalent to
DoubleStream.forEachOrdered(java.util.function.DoubleConsumer) . |
java.util.PrimitiveIterator.OfDouble |
iterator() |
AsyncDoubleStream |
limit(long maxSize)
An asynchronous equivalent to
DoubleStream.limit(long) . |
AsyncDoubleStream |
map(java.util.function.DoubleUnaryOperator mapper)
An asynchronous equivalent to
DoubleStream.map(java.util.function.DoubleUnaryOperator) . |
AsyncIntStream |
mapToInt(java.util.function.DoubleToIntFunction mapper)
An asynchronous equivalent to
DoubleStream.mapToInt(java.util.function.DoubleToIntFunction) . |
AsyncLongStream |
mapToLong(java.util.function.DoubleToLongFunction mapper)
An asynchronous equivalent to
DoubleStream.mapToLong(java.util.function.DoubleToLongFunction) . |
<U> AsyncStream<U> |
mapToObj(java.util.function.DoubleFunction<? extends U> mapper)
An asynchronous equivalent to
DoubleStream.mapToObj(java.util.function.DoubleFunction) . |
Operation<java.util.OptionalDouble> |
max()
An asynchronous equivalent to
DoubleStream.max() . |
Operation<java.util.OptionalDouble> |
min()
An asynchronous equivalent to
DoubleStream.min() . |
Operation<java.lang.Boolean> |
noneMatch(java.util.function.DoublePredicate predicate)
An asynchronous equivalent to
DoubleStream.noneMatch(java.util.function.DoublePredicate) . |
AsyncDoubleStream |
parallel() |
AsyncDoubleStream |
peek(java.util.function.DoubleConsumer action)
An asynchronous equivalent to
DoubleStream.peek(java.util.function.DoubleConsumer) . |
Operation<java.util.OptionalDouble> |
reduce(java.util.function.DoubleBinaryOperator op)
An asynchronous equivalent to
DoubleStream.reduce(java.util.function.DoubleBinaryOperator) . |
Operation<java.lang.Double> |
reduce(double identity,
java.util.function.DoubleBinaryOperator op)
An asynchronous equivalent to
DoubleStream.reduce(double, 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() . |
java.util.Spliterator.OfDouble |
spliterator() |
Operation<java.lang.Double> |
sum()
An asynchronous equivalent to
DoubleStream.sum() . |
Operation<java.util.DoubleSummaryStatistics> |
summaryStatistics()
An asynchronous equivalent to
DoubleStream.summaryStatistics() . |
Operation<double[]> |
toArray()
An asynchronous equivalent to
DoubleStream.toArray() . |
AsyncDoubleStream filter(java.util.function.DoublePredicate predicate)
DoubleStream.filter(java.util.function.DoublePredicate)
.predicate
- the inclusion predicateAsyncDoubleStream map(java.util.function.DoubleUnaryOperator mapper)
DoubleStream.map(java.util.function.DoubleUnaryOperator)
.mapper
- the element mapping function<U> AsyncStream<U> mapToObj(java.util.function.DoubleFunction<? extends U> mapper)
DoubleStream.mapToObj(java.util.function.DoubleFunction)
.U
- the element type of the new streammapper
- the element mapping functionAsyncIntStream mapToInt(java.util.function.DoubleToIntFunction mapper)
DoubleStream.mapToInt(java.util.function.DoubleToIntFunction)
.mapper
- the element mapping functionAsyncLongStream mapToLong(java.util.function.DoubleToLongFunction mapper)
DoubleStream.mapToLong(java.util.function.DoubleToLongFunction)
.mapper
- the element mapping functionAsyncDoubleStream flatMap(java.util.function.DoubleFunction<? extends java.util.stream.DoubleStream> mapper)
DoubleStream.flatMap(java.util.function.DoubleFunction)
.mapper
- the element mapping functionAsyncDoubleStream distinct()
DoubleStream.distinct()
.AsyncDoubleStream sorted()
DoubleStream.sorted()
.AsyncDoubleStream peek(java.util.function.DoubleConsumer action)
DoubleStream.peek(java.util.function.DoubleConsumer)
.action
- action to perform on the elements as they are consumedAsyncDoubleStream limit(long maxSize)
DoubleStream.limit(long)
.maxSize
- maximum number of elementsAsyncDoubleStream skip(long n)
DoubleStream.skip(long)
.n
- number of leading elements to skipOperation<java.lang.Void> forEach(java.util.function.DoubleConsumer action)
DoubleStream.forEach(java.util.function.DoubleConsumer)
.action
- action to perform on the elementsOperation
representing the completion of this action across all elementsOperation<java.lang.Void> forEachOrdered(java.util.function.DoubleConsumer action)
DoubleStream.forEachOrdered(java.util.function.DoubleConsumer)
.action
- action to perform on the elementsOperation
representing the completion of this action across all elementsOperation<double[]> toArray()
DoubleStream.toArray()
.Operation
representing the conversion of this stream to an arrayOperation<java.lang.Double> reduce(double identity, java.util.function.DoubleBinaryOperator op)
DoubleStream.reduce(double, java.util.function.DoubleBinaryOperator)
.identity
- identity value of the accumulating operatorop
- the accumulating operatorOperation
representing the execution of this reductionOperation<java.util.OptionalDouble> reduce(java.util.function.DoubleBinaryOperator op)
DoubleStream.reduce(java.util.function.DoubleBinaryOperator)
.op
- the accumulating operatorOperation
representing the execution of this reduction<R> Operation<R> collect(java.util.function.Supplier<R> supplier, java.util.function.ObjDoubleConsumer<R> accumulator, java.util.function.BiConsumer<R,R> combiner)
DoubleStream.collect(java.util.function.Supplier, java.util.function.ObjDoubleConsumer, java.util.function.BiConsumer)
.R
- the type of the resultsupplier
- the result container supplieraccumulator
- the accumulating functioncombiner
- the combining functionOperation
representing the execution of this reductionOperation<java.lang.Double> sum()
DoubleStream.sum()
.Operation
representing the sum of all elementsOperation<java.util.OptionalDouble> min()
DoubleStream.min()
.Operation
representing the calculation of the minimum valueOperation<java.util.OptionalDouble> max()
DoubleStream.max()
.Operation
representing the calculation of the maximum valueOperation<java.lang.Long> count()
DoubleStream.count()
.Operation
representing the length of the streamOperation<java.util.OptionalDouble> average()
DoubleStream.average()
.Operation
representing the calculation of the average of all elementsOperation<java.util.DoubleSummaryStatistics> summaryStatistics()
DoubleStream.summaryStatistics()
.Operation
representing the calculation of statistics for this stream.Operation<java.lang.Boolean> anyMatch(java.util.function.DoublePredicate predicate)
DoubleStream.anyMatch(java.util.function.DoublePredicate)
.predicate
- predicate to apply to the elements in the streamOperation
returning true
if at least one elements satisfies the predicateOperation<java.lang.Boolean> allMatch(java.util.function.DoublePredicate predicate)
DoubleStream.allMatch(java.util.function.DoublePredicate)
.predicate
- predicate to apply to the elements in the streamOperation
returning true
if all the elements satisfy the predicateOperation<java.lang.Boolean> noneMatch(java.util.function.DoublePredicate predicate)
DoubleStream.noneMatch(java.util.function.DoublePredicate)
.predicate
- predicate to apply to the elements in the streamOperation
returning true
if none of the elements satisfy the predicateOperation<java.util.OptionalDouble> findFirst()
DoubleStream.findFirst()
.Operation
returning the first element of the streamOperation<java.util.OptionalDouble> findAny()
DoubleStream.findAny()
.Operation
returning an element of the streamAsyncStream<java.lang.Double> boxed()
DoubleStream.boxed()
.AsyncStream
containing boxed versions of this streams valuesAsyncDoubleStream sequential()
sequential
in interface java.util.stream.BaseStream<java.lang.Double,AsyncDoubleStream>
AsyncDoubleStream parallel()
parallel
in interface java.util.stream.BaseStream<java.lang.Double,AsyncDoubleStream>
java.util.PrimitiveIterator.OfDouble iterator()
iterator
in interface java.util.stream.BaseStream<java.lang.Double,AsyncDoubleStream>
java.util.Spliterator.OfDouble spliterator()
spliterator
in interface java.util.stream.BaseStream<java.lang.Double,AsyncDoubleStream>