public interface AsyncRecordStream<K extends java.lang.Comparable<K>> extends AsyncStream<Record<K>>
RecordStream
.Modifier and Type | Method and Description |
---|---|
AsyncRecordStream<K> |
distinct()
An asynchronous equivalent to
Stream.distinct() . |
AsyncRecordStream<K> |
explain(java.util.function.Consumer<java.lang.Object> consumer)
An asynchronous equivalent to
RecordStream.explain(Consumer) . |
AsyncRecordStream<K> |
filter(java.util.function.Predicate<? super Record<K>> predicate)
An asynchronous equivalent to
Stream.filter(java.util.function.Predicate) . |
AsyncRecordStream<K> |
limit(long maxSize)
An asynchronous equivalent to
Stream.limit(long) . |
AsyncRecordStream<K> |
onClose(java.lang.Runnable closeHandler) |
AsyncRecordStream<K> |
parallel() |
AsyncRecordStream<K> |
peek(java.util.function.Consumer<? super Record<K>> action)
An asynchronous equivalent to
Stream.peek(java.util.function.Consumer) . |
AsyncRecordStream<K> |
sequential() |
AsyncRecordStream<K> |
skip(long n)
An asynchronous equivalent to
Stream.skip(long) . |
AsyncRecordStream<K> |
sorted()
An asynchronous equivalent to
Stream.sorted() . |
AsyncRecordStream<K> |
sorted(java.util.Comparator<? super Record<K>> comparator)
An asynchronous equivalent to
Stream.sorted(java.util.Comparator) . |
AsyncRecordStream<K> |
unordered() |
allMatch, anyMatch, collect, collect, count, findAny, findFirst, flatMap, flatMapToDouble, flatMapToInt, flatMapToLong, forEach, forEachOrdered, map, mapToDouble, mapToInt, mapToLong, max, min, noneMatch, reduce, reduce, reduce, toArray, toArray
AsyncRecordStream<K> explain(java.util.function.Consumer<java.lang.Object> consumer)
RecordStream.explain(Consumer)
.consumer
- the explain consumerAsyncRecordStream<K> filter(java.util.function.Predicate<? super Record<K>> predicate)
AsyncStream
Stream.filter(java.util.function.Predicate)
.filter
in interface AsyncStream<Record<K extends java.lang.Comparable<K>>>
predicate
- the inclusion predicateAsyncRecordStream<K> distinct()
AsyncStream
Stream.distinct()
.distinct
in interface AsyncStream<Record<K extends java.lang.Comparable<K>>>
AsyncRecordStream<K> sorted()
AsyncStream
Stream.sorted()
.sorted
in interface AsyncStream<Record<K extends java.lang.Comparable<K>>>
AsyncRecordStream<K> sorted(java.util.Comparator<? super Record<K>> comparator)
AsyncStream
Stream.sorted(java.util.Comparator)
.sorted
in interface AsyncStream<Record<K extends java.lang.Comparable<K>>>
comparator
- comparator used to compare the elementsAsyncRecordStream<K> peek(java.util.function.Consumer<? super Record<K>> action)
AsyncStream
Stream.peek(java.util.function.Consumer)
.peek
in interface AsyncStream<Record<K extends java.lang.Comparable<K>>>
action
- action to perform on the elements as they are consumedAsyncRecordStream<K> limit(long maxSize)
AsyncStream
Stream.limit(long)
.limit
in interface AsyncStream<Record<K extends java.lang.Comparable<K>>>
maxSize
- maximum number of elementsAsyncRecordStream<K> skip(long n)
AsyncStream
Stream.skip(long)
.skip
in interface AsyncStream<Record<K extends java.lang.Comparable<K>>>
n
- number of leading elements to skipAsyncRecordStream<K> sequential()
AsyncRecordStream<K> parallel()
AsyncRecordStream<K> unordered()
AsyncRecordStream<K> onClose(java.lang.Runnable closeHandler)