public interface AsyncLongStream extends java.util.stream.BaseStream<java.lang.Long,AsyncLongStream>
LongStream
.LongStream
Modifier and Type | Method and Description |
---|---|
Operation<java.lang.Boolean> |
allMatch(java.util.function.LongPredicate predicate)
An asynchronous equivalent to
LongStream.allMatch(java.util.function.LongPredicate) . |
Operation<java.lang.Boolean> |
anyMatch(java.util.function.LongPredicate predicate)
An asynchronous equivalent to
LongStream.anyMatch(java.util.function.LongPredicate) . |
AsyncDoubleStream |
asDoubleStream()
An asynchronous equivalent to
LongStream.asDoubleStream() . |
Operation<java.util.OptionalDouble> |
average()
An asynchronous equivalent to
LongStream.average() . |
AsyncStream<java.lang.Long> |
boxed()
An asynchronous equivalent to
LongStream.boxed() . |
<R> Operation<R> |
collect(java.util.function.Supplier<R> supplier,
java.util.function.ObjLongConsumer<R> accumulator,
java.util.function.BiConsumer<R,R> combiner)
An asynchronous equivalent to
LongStream.collect(java.util.function.Supplier, java.util.function.ObjLongConsumer, java.util.function.BiConsumer) . |
Operation<java.lang.Long> |
count()
An asynchronous equivalent to
LongStream.count() . |
AsyncLongStream |
distinct()
An asynchronous equivalent to
LongStream.distinct() . |
AsyncLongStream |
filter(java.util.function.LongPredicate predicate)
An asynchronous equivalent to
LongStream.filter(java.util.function.LongPredicate) . |
Operation<java.util.OptionalLong> |
findAny()
An asynchronous equivalent to
LongStream.findAny() . |
Operation<java.util.OptionalLong> |
findFirst()
An asynchronous equivalent to
LongStream.findFirst() . |
AsyncLongStream |
flatMap(java.util.function.LongFunction<? extends java.util.stream.LongStream> mapper)
An asynchronous equivalent to
LongStream.flatMap(java.util.function.LongFunction) . |
Operation<java.lang.Void> |
forEach(java.util.function.LongConsumer action)
An asynchronous equivalent to
LongStream.forEach(java.util.function.LongConsumer) . |
Operation<java.lang.Void> |
forEachOrdered(java.util.function.LongConsumer action)
An asynchronous equivalent to
LongStream.forEachOrdered(java.util.function.LongConsumer) . |
java.util.PrimitiveIterator.OfLong |
iterator() |
AsyncLongStream |
limit(long maxSize)
An asynchronous equivalent to
LongStream.limit(long) . |
AsyncLongStream |
map(java.util.function.LongUnaryOperator mapper)
An asynchronous equivalent to
LongStream.map(java.util.function.LongUnaryOperator) . |
AsyncDoubleStream |
mapToDouble(java.util.function.LongToDoubleFunction mapper)
An asynchronous equivalent to
LongStream.mapToDouble(java.util.function.LongToDoubleFunction) . |
AsyncIntStream |
mapToInt(java.util.function.LongToIntFunction mapper)
An asynchronous equivalent to
LongStream.mapToInt(java.util.function.LongToIntFunction) . |
<U> AsyncStream<U> |
mapToObj(java.util.function.LongFunction<? extends U> mapper)
An asynchronous equivalent to
LongStream.mapToObj(java.util.function.LongFunction) . |
Operation<java.util.OptionalLong> |
max()
An asynchronous equivalent to
LongStream.max() . |
Operation<java.util.OptionalLong> |
min()
An asynchronous equivalent to
LongStream.min() . |
Operation<java.lang.Boolean> |
noneMatch(java.util.function.LongPredicate predicate)
An asynchronous equivalent to
LongStream.noneMatch(java.util.function.LongPredicate) . |
AsyncLongStream |
parallel() |
AsyncLongStream |
peek(java.util.function.LongConsumer action)
An asynchronous equivalent to
LongStream.peek(java.util.function.LongConsumer) . |
Operation<java.util.OptionalLong> |
reduce(java.util.function.LongBinaryOperator op)
An asynchronous equivalent to
LongStream.reduce(java.util.function.LongBinaryOperator) . |
Operation<java.lang.Long> |
reduce(long identity,
java.util.function.LongBinaryOperator op)
An asynchronous equivalent to
LongStream.reduce(long, 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() . |
java.util.Spliterator.OfLong |
spliterator() |
Operation<java.lang.Long> |
sum()
An asynchronous equivalent to
LongStream.sum() . |
Operation<java.util.LongSummaryStatistics> |
summaryStatistics()
An asynchronous equivalent to
LongStream.summaryStatistics() . |
Operation<long[]> |
toArray()
An asynchronous equivalent to
LongStream.toArray() . |
AsyncLongStream filter(java.util.function.LongPredicate predicate)
LongStream.filter(java.util.function.LongPredicate)
.predicate
- the inclusion predicateAsyncLongStream map(java.util.function.LongUnaryOperator mapper)
LongStream.map(java.util.function.LongUnaryOperator)
.mapper
- the element mapping function<U> AsyncStream<U> mapToObj(java.util.function.LongFunction<? extends U> mapper)
LongStream.mapToObj(java.util.function.LongFunction)
.U
- the element type of the new streammapper
- the element mapping functionAsyncIntStream mapToInt(java.util.function.LongToIntFunction mapper)
LongStream.mapToInt(java.util.function.LongToIntFunction)
.mapper
- the element mapping functionAsyncDoubleStream mapToDouble(java.util.function.LongToDoubleFunction mapper)
LongStream.mapToDouble(java.util.function.LongToDoubleFunction)
.mapper
- the element mapping functionAsyncLongStream flatMap(java.util.function.LongFunction<? extends java.util.stream.LongStream> mapper)
LongStream.flatMap(java.util.function.LongFunction)
.mapper
- the element mapping functionAsyncLongStream distinct()
LongStream.distinct()
.AsyncLongStream sorted()
LongStream.sorted()
.AsyncLongStream peek(java.util.function.LongConsumer action)
LongStream.peek(java.util.function.LongConsumer)
.action
- action to perform on the elements as they are consumedAsyncLongStream limit(long maxSize)
LongStream.limit(long)
.maxSize
- maximum number of elementsAsyncLongStream skip(long n)
LongStream.skip(long)
.n
- number of leading elements to skipOperation<java.lang.Void> forEach(java.util.function.LongConsumer action)
LongStream.forEach(java.util.function.LongConsumer)
.action
- action to perform on the elementsOperation
representing the completion of this action across all elementsOperation<java.lang.Void> forEachOrdered(java.util.function.LongConsumer action)
LongStream.forEachOrdered(java.util.function.LongConsumer)
.action
- action to perform on the elementsOperation
representing the completion of this action across all elementsOperation<long[]> toArray()
LongStream.toArray()
.Operation
representing the conversion of this stream to an arrayOperation<java.lang.Long> reduce(long identity, java.util.function.LongBinaryOperator op)
LongStream.reduce(long, java.util.function.LongBinaryOperator)
.identity
- identity value of the accumulating operatorop
- the accumulating operatorOperation
representing the execution of this reductionOperation<java.util.OptionalLong> reduce(java.util.function.LongBinaryOperator op)
LongStream.reduce(java.util.function.LongBinaryOperator)
.op
- the accumulating operatorOperation
representing the execution of this reduction<R> Operation<R> collect(java.util.function.Supplier<R> supplier, java.util.function.ObjLongConsumer<R> accumulator, java.util.function.BiConsumer<R,R> combiner)
LongStream.collect(java.util.function.Supplier, java.util.function.ObjLongConsumer, 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.Long> sum()
LongStream.sum()
.Operation
representing the sum of all elementsOperation<java.util.OptionalLong> min()
LongStream.min()
.Operation
representing the calculation of the minimum valueOperation<java.util.OptionalLong> max()
LongStream.max()
.Operation
representing the calculation of the maximum valueOperation<java.lang.Long> count()
LongStream.count()
.Operation
representing the length of the streamOperation<java.util.OptionalDouble> average()
LongStream.average()
.Operation
representing the calculation of the average of all elementsOperation<java.util.LongSummaryStatistics> summaryStatistics()
LongStream.summaryStatistics()
.Operation
representing the calculation of statistics for this stream.Operation<java.lang.Boolean> anyMatch(java.util.function.LongPredicate predicate)
LongStream.anyMatch(java.util.function.LongPredicate)
.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.LongPredicate predicate)
LongStream.allMatch(java.util.function.LongPredicate)
.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.LongPredicate predicate)
LongStream.noneMatch(java.util.function.LongPredicate)
.predicate
- predicate to apply to the elements in the streamOperation
returning true
if none of the elements satisfy the predicateOperation<java.util.OptionalLong> findFirst()
LongStream.findFirst()
.Operation
returning the first element of the streamOperation<java.util.OptionalLong> findAny()
LongStream.findAny()
.Operation
returning an element of the streamAsyncDoubleStream asDoubleStream()
LongStream.asDoubleStream()
.AsyncDoubleStream
containing these values converted to doublesAsyncStream<java.lang.Long> boxed()
LongStream.boxed()
.AsyncStream
containing boxed versions of this streams valuesAsyncLongStream sequential()
sequential
in interface java.util.stream.BaseStream<java.lang.Long,AsyncLongStream>
AsyncLongStream parallel()
parallel
in interface java.util.stream.BaseStream<java.lang.Long,AsyncLongStream>
java.util.PrimitiveIterator.OfLong iterator()
iterator
in interface java.util.stream.BaseStream<java.lang.Long,AsyncLongStream>
java.util.Spliterator.OfLong spliterator()
spliterator
in interface java.util.stream.BaseStream<java.lang.Long,AsyncLongStream>