public interface AsyncMutableRecordStream<K extends java.lang.Comparable<K>> extends AsyncRecordStream<K>
MutableRecordStream
.Modifier and Type | Method and Description |
---|---|
Operation<java.lang.Void> |
delete()
Deletes every
Record in the stream. |
AsyncStream<Record<K>> |
deleteThen()
Deletes every
Record in the stream. |
AsyncMutableRecordStream<K> |
distinct()
An asynchronous equivalent to
Stream.distinct() . |
AsyncMutableRecordStream<K> |
explain(java.util.function.Consumer<java.lang.Object> consumer)
An asynchronous equivalent to
RecordStream.explain(Consumer) . |
AsyncMutableRecordStream<K> |
filter(java.util.function.Predicate<? super Record<K>> predicate)
An asynchronous equivalent to
Stream.filter(java.util.function.Predicate) . |
AsyncMutableRecordStream<K> |
limit(long maxSize)
An asynchronous equivalent to
Stream.limit(long) . |
Operation<java.lang.Void> |
mutate(UpdateOperation<? super K> transform)
Performs an update transformation against the
Record s in the stream. |
AsyncStream<Tuple<Record<K>,Record<K>>> |
mutateThen(UpdateOperation<? super K> transform)
Performs an update transformation against the
Record s in the stream. |
AsyncMutableRecordStream<K> |
onClose(java.lang.Runnable closeHandler) |
AsyncMutableRecordStream<K> |
parallel() |
AsyncMutableRecordStream<K> |
peek(java.util.function.Consumer<? super Record<K>> action)
An asynchronous equivalent to
Stream.peek(java.util.function.Consumer) . |
AsyncMutableRecordStream<K> |
sequential() |
AsyncMutableRecordStream<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) . |
AsyncMutableRecordStream<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
Operation<java.lang.Void> mutate(UpdateOperation<? super K> transform)
Record
s in the stream.
This is a terminal operation.
transform
- the transformation to performAsyncStream<Tuple<Record<K>,Record<K>>> mutateThen(UpdateOperation<? super K> transform)
Record
s in the stream.
This is an intermediate operation.
transform
- the transformation to performStream
of new Tuple
s holding before and after Record
instancesOperation<java.lang.Void> delete()
Record
in the stream.
This is a terminal operation.
AsyncStream<Record<K>> deleteThen()
Record
in the stream.
This is an intermediate operation.
Stream
of the deleted Record
sAsyncMutableRecordStream<K> explain(java.util.function.Consumer<java.lang.Object> consumer)
AsyncRecordStream
RecordStream.explain(Consumer)
.explain
in interface AsyncRecordStream<K extends java.lang.Comparable<K>>
consumer
- the explain consumerAsyncMutableRecordStream<K> filter(java.util.function.Predicate<? super Record<K>> predicate)
AsyncStream
Stream.filter(java.util.function.Predicate)
.filter
in interface AsyncRecordStream<K extends java.lang.Comparable<K>>
filter
in interface AsyncStream<Record<K extends java.lang.Comparable<K>>>
predicate
- the inclusion predicateAsyncMutableRecordStream<K> distinct()
AsyncStream
Stream.distinct()
.distinct
in interface AsyncRecordStream<K extends java.lang.Comparable<K>>
distinct
in interface AsyncStream<Record<K extends java.lang.Comparable<K>>>
AsyncRecordStream<K> sorted()
AsyncStream
Stream.sorted()
.sorted
in interface AsyncRecordStream<K extends java.lang.Comparable<K>>
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 AsyncRecordStream<K extends java.lang.Comparable<K>>
sorted
in interface AsyncStream<Record<K extends java.lang.Comparable<K>>>
comparator
- comparator used to compare the elementsAsyncMutableRecordStream<K> peek(java.util.function.Consumer<? super Record<K>> action)
AsyncStream
Stream.peek(java.util.function.Consumer)
.peek
in interface AsyncRecordStream<K extends java.lang.Comparable<K>>
peek
in interface AsyncStream<Record<K extends java.lang.Comparable<K>>>
action
- action to perform on the elements as they are consumedAsyncMutableRecordStream<K> limit(long maxSize)
AsyncStream
Stream.limit(long)
.limit
in interface AsyncRecordStream<K extends java.lang.Comparable<K>>
limit
in interface AsyncStream<Record<K extends java.lang.Comparable<K>>>
maxSize
- maximum number of elementsAsyncMutableRecordStream<K> skip(long n)
AsyncStream
Stream.skip(long)
.skip
in interface AsyncRecordStream<K extends java.lang.Comparable<K>>
skip
in interface AsyncStream<Record<K extends java.lang.Comparable<K>>>
n
- number of leading elements to skipAsyncMutableRecordStream<K> sequential()
sequential
in interface AsyncRecordStream<K extends java.lang.Comparable<K>>
sequential
in interface java.util.stream.BaseStream<Record<K extends java.lang.Comparable<K>>,AsyncStream<Record<K extends java.lang.Comparable<K>>>>
AsyncMutableRecordStream<K> parallel()
AsyncMutableRecordStream<K> unordered()
AsyncMutableRecordStream<K> onClose(java.lang.Runnable closeHandler)