public interface AsyncIntStream extends java.util.stream.BaseStream<java.lang.Integer,AsyncIntStream>
IntStream
.IntStream
Modifier and Type | Method and Description |
---|---|
Operation<java.lang.Boolean> |
allMatch(java.util.function.IntPredicate predicate)
An asynchronous equivalent to
IntStream.allMatch(java.util.function.IntPredicate) . |
Operation<java.lang.Boolean> |
anyMatch(java.util.function.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<java.util.OptionalDouble> |
average()
An asynchronous equivalent to
IntStream.average() . |
AsyncStream<java.lang.Integer> |
boxed()
An asynchronous equivalent to
IntStream.boxed() . |
<R> Operation<R> |
collect(java.util.function.Supplier<R> supplier,
java.util.function.ObjIntConsumer<R> accumulator,
java.util.function.BiConsumer<R,R> combiner)
An asynchronous equivalent to
IntStream.collect(java.util.function.Supplier, java.util.function.ObjIntConsumer, java.util.function.BiConsumer) . |
Operation<java.lang.Long> |
count()
An asynchronous equivalent to
IntStream.count() . |
AsyncIntStream |
distinct()
An asynchronous equivalent to
IntStream.distinct() . |
AsyncIntStream |
filter(java.util.function.IntPredicate predicate)
An asynchronous equivalent to
IntStream.filter(java.util.function.IntPredicate) . |
Operation<java.util.OptionalInt> |
findAny()
An asynchronous equivalent to
IntStream.findAny() . |
Operation<java.util.OptionalInt> |
findFirst()
An asynchronous equivalent to
IntStream.findFirst() . |
AsyncIntStream |
flatMap(java.util.function.IntFunction<? extends java.util.stream.IntStream> mapper)
An asynchronous equivalent to
IntStream.flatMap(java.util.function.IntFunction) . |
Operation<java.lang.Void> |
forEach(java.util.function.IntConsumer action)
An asynchronous equivalent to
IntStream.forEach(java.util.function.IntConsumer) . |
Operation<java.lang.Void> |
forEachOrdered(java.util.function.IntConsumer action)
An asynchronous equivalent to
IntStream.forEachOrdered(java.util.function.IntConsumer) . |
java.util.PrimitiveIterator.OfInt |
iterator() |
AsyncIntStream |
limit(long maxSize)
An asynchronous equivalent to
IntStream.limit(long) . |
AsyncIntStream |
map(java.util.function.IntUnaryOperator mapper)
An asynchronous equivalent to
IntStream.map(java.util.function.IntUnaryOperator) . |
AsyncDoubleStream |
mapToDouble(java.util.function.IntToDoubleFunction mapper)
An asynchronous equivalent to
IntStream.mapToDouble(java.util.function.IntToDoubleFunction) . |
AsyncLongStream |
mapToLong(java.util.function.IntToLongFunction mapper)
An asynchronous equivalent to
IntStream.mapToLong(java.util.function.IntToLongFunction) . |
<U> AsyncStream<U> |
mapToObj(java.util.function.IntFunction<? extends U> mapper)
An asynchronous equivalent to
IntStream.mapToObj(java.util.function.IntFunction) . |
Operation<java.util.OptionalInt> |
max()
An asynchronous equivalent to
IntStream.max() . |
Operation<java.util.OptionalInt> |
min()
An asynchronous equivalent to
IntStream.min() . |
Operation<java.lang.Boolean> |
noneMatch(java.util.function.IntPredicate predicate)
An asynchronous equivalent to
IntStream.noneMatch(java.util.function.IntPredicate) . |
AsyncIntStream |
parallel() |
AsyncIntStream |
peek(java.util.function.IntConsumer action)
An asynchronous equivalent to
IntStream.peek(java.util.function.IntConsumer) . |
Operation<java.util.OptionalInt> |
reduce(java.util.function.IntBinaryOperator op)
An asynchronous equivalent to
IntStream.reduce(java.util.function.IntBinaryOperator) . |
Operation<java.lang.Integer> |
reduce(int identity,
java.util.function.IntBinaryOperator op)
An asynchronous equivalent to
IntStream.reduce(int, 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() . |
java.util.Spliterator.OfInt |
spliterator() |
Operation<java.lang.Integer> |
sum()
An asynchronous equivalent to
IntStream.sum() . |
Operation<java.util.IntSummaryStatistics> |
summaryStatistics()
An asynchronous equivalent to
IntStream.summaryStatistics() . |
Operation<int[]> |
toArray()
An asynchronous equivalent to
IntStream.toArray() . |
AsyncIntStream filter(java.util.function.IntPredicate predicate)
IntStream.filter(java.util.function.IntPredicate)
.predicate
- the inclusion predicateAsyncIntStream map(java.util.function.IntUnaryOperator mapper)
IntStream.map(java.util.function.IntUnaryOperator)
.mapper
- the element mapping function<U> AsyncStream<U> mapToObj(java.util.function.IntFunction<? extends U> mapper)
IntStream.mapToObj(java.util.function.IntFunction)
.U
- the element type of the new streammapper
- the element mapping functionAsyncLongStream mapToLong(java.util.function.IntToLongFunction mapper)
IntStream.mapToLong(java.util.function.IntToLongFunction)
.mapper
- the element mapping functionAsyncDoubleStream mapToDouble(java.util.function.IntToDoubleFunction mapper)
IntStream.mapToDouble(java.util.function.IntToDoubleFunction)
.mapper
- the element mapping functionAsyncIntStream flatMap(java.util.function.IntFunction<? extends java.util.stream.IntStream> mapper)
IntStream.flatMap(java.util.function.IntFunction)
.mapper
- the element mapping functionAsyncIntStream distinct()
IntStream.distinct()
.AsyncIntStream sorted()
IntStream.sorted()
.AsyncIntStream peek(java.util.function.IntConsumer action)
IntStream.peek(java.util.function.IntConsumer)
.action
- action to perform on the elements as they are consumedAsyncIntStream limit(long maxSize)
IntStream.limit(long)
.maxSize
- maximum number of elementsAsyncIntStream skip(long n)
IntStream.skip(long)
.n
- number of leading elements to skipOperation<java.lang.Void> forEach(java.util.function.IntConsumer action)
IntStream.forEach(java.util.function.IntConsumer)
.action
- action to perform on the elementsOperation
representing the completion of this action across all elementsOperation<java.lang.Void> forEachOrdered(java.util.function.IntConsumer action)
IntStream.forEachOrdered(java.util.function.IntConsumer)
.action
- action to perform on the elementsOperation
representing the completion of this action across all elementsOperation<int[]> toArray()
IntStream.toArray()
.Operation
representing the conversion of this stream to an arrayOperation<java.lang.Integer> reduce(int identity, java.util.function.IntBinaryOperator op)
IntStream.reduce(int, java.util.function.IntBinaryOperator)
.identity
- identity value of the accumulating operatorop
- the accumulating operatorOperation
representing the execution of this reductionOperation<java.util.OptionalInt> reduce(java.util.function.IntBinaryOperator op)
IntStream.reduce(java.util.function.IntBinaryOperator)
.op
- the accumulating operatorOperation
representing the execution of this reduction<R> Operation<R> collect(java.util.function.Supplier<R> supplier, java.util.function.ObjIntConsumer<R> accumulator, java.util.function.BiConsumer<R,R> combiner)
IntStream.collect(java.util.function.Supplier, java.util.function.ObjIntConsumer, 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.Integer> sum()
IntStream.sum()
.Operation
representing the sum of all elementsOperation<java.util.OptionalInt> min()
IntStream.min()
.Operation
representing the calculation of the minimum valueOperation<java.util.OptionalInt> max()
IntStream.max()
.Operation
representing the calculation of the maximum valueOperation<java.lang.Long> count()
IntStream.count()
.Operation
representing the length of the streamOperation<java.util.OptionalDouble> average()
IntStream.average()
.Operation
representing the calculation of the average of all elementsOperation<java.util.IntSummaryStatistics> summaryStatistics()
IntStream.summaryStatistics()
.Operation
representing the calculation of statistics for this stream.Operation<java.lang.Boolean> anyMatch(java.util.function.IntPredicate predicate)
IntStream.anyMatch(java.util.function.IntPredicate)
.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.IntPredicate predicate)
IntStream.allMatch(java.util.function.IntPredicate)
.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.IntPredicate predicate)
IntStream.noneMatch(java.util.function.IntPredicate)
.predicate
- predicate to apply to the elements in the streamOperation
returning true
if none of the elements satisfy the predicateOperation<java.util.OptionalInt> findFirst()
IntStream.findFirst()
.Operation
returning the first element of the streamOperation<java.util.OptionalInt> findAny()
IntStream.findAny()
.Operation
returning an element of the streamAsyncLongStream asLongStream()
IntStream.asLongStream()
.AsyncLongStream
containing these values converted to longsAsyncDoubleStream asDoubleStream()
IntStream.asDoubleStream()
.AsyncDoubleStream
containing these values converted to doublesAsyncStream<java.lang.Integer> boxed()
IntStream.boxed()
.AsyncStream
containing boxed versions of this streams valuesAsyncIntStream sequential()
sequential
in interface java.util.stream.BaseStream<java.lang.Integer,AsyncIntStream>
AsyncIntStream parallel()
parallel
in interface java.util.stream.BaseStream<java.lang.Integer,AsyncIntStream>
java.util.PrimitiveIterator.OfInt iterator()
iterator
in interface java.util.stream.BaseStream<java.lang.Integer,AsyncIntStream>
java.util.Spliterator.OfInt spliterator()
spliterator
in interface java.util.stream.BaseStream<java.lang.Integer,AsyncIntStream>