Package com.terracottatech.store.async

Interface AsyncMutableRecordStream<K extends Comparable<K>>

All Superinterfaces:

AsyncRecordStream<K>, AsyncStream<Record<K>>, AutoCloseable, BaseStream<Record<K>,AsyncStream<Record<K>>>

public interface AsyncMutableRecordStream<K extends Comparable<K>>
extends AsyncRecordStream<K>

Asynchronous equivalent to MutableRecordStream.

Method Summary

Modifier and Type	Method	Description
Operation<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(Consumer<Object> consumer)	An asynchronous equivalent to RecordStream.explain(Consumer).
AsyncMutableRecordStream<K>	filter(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<Void>	mutate(UpdateOperation<? super K> transform)	Performs an update transformation against the Records in the stream.
AsyncStream<Tuple<Record<K>,Record<K>>>	mutateThen(UpdateOperation<? super K> transform)	Performs an update transformation against the Records in the stream.
AsyncMutableRecordStream<K>	onClose(Runnable closeHandler)
AsyncMutableRecordStream<K>	parallel()
AsyncMutableRecordStream<K>	peek(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(Comparator<? super Record<K>> comparator)	An asynchronous equivalent to Stream.sorted(java.util.Comparator).
AsyncMutableRecordStream<K>	unordered()

Methods inherited from interface com.terracottatech.store.async.AsyncStream

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

Methods inherited from interface java.util.stream.BaseStream

close, isParallel, iterator, spliterator

Method Details

mutate

Operation<Void> mutate(UpdateOperation<? super K> transform)

Performs an update transformation against the Records in the stream.

This is a terminal operation.

Parameters:

transform - the transformation to perform

Returns:

the asynchronous mutation

mutateThen

AsyncStream<Tuple<Record<K>,Record<K>>> mutateThen(UpdateOperation<? super K> transform)

Performs an update transformation against the Records in the stream.

This is an intermediate operation.

Parameters:

transform - the transformation to perform

Returns:

a Stream of new Tuples holding before and after Record instances

delete

Operation<Void> delete()

Deletes every Record in the stream.

This is a terminal operation.

Returns:

the asynchronous deletion

deleteThen

AsyncStream<Record<K>> deleteThen()

Deletes every Record in the stream.

This is an intermediate operation.

Returns:

a Stream of the deleted Records

explain

AsyncMutableRecordStream<K> explain(Consumer<Object> consumer)

Description copied from interface: AsyncRecordStream

An asynchronous equivalent to RecordStream.explain(Consumer).

Specified by:

explain in interface AsyncRecordStream<K extends Comparable<K>>

Parameters:

consumer - the explain consumer

Returns:

the new stream

filter

AsyncMutableRecordStream<K> filter(Predicate<? super Record<K>> predicate)

Description copied from interface: AsyncStream

An asynchronous equivalent to Stream.filter(java.util.function.Predicate).

Specified by:

filter in interface AsyncRecordStream<K extends Comparable<K>>

Specified by:

filter in interface AsyncStream<K extends Comparable<K>>

Parameters:

predicate - the inclusion predicate

Returns:

the new stream

distinct

AsyncMutableRecordStream<K> distinct()

Description copied from interface: AsyncStream

An asynchronous equivalent to Stream.distinct().

Specified by:

distinct in interface AsyncRecordStream<K extends Comparable<K>>

Specified by:

distinct in interface AsyncStream<K extends Comparable<K>>

Returns:

the new stream

sorted

AsyncRecordStream<K> sorted()

Description copied from interface: AsyncStream

An asynchronous equivalent to Stream.sorted().

Specified by:

sorted in interface AsyncRecordStream<K extends Comparable<K>>

Specified by:

sorted in interface AsyncStream<K extends Comparable<K>>

Returns:

the new stream

sorted

AsyncRecordStream<K> sorted(Comparator<? super Record<K>> comparator)

Description copied from interface: AsyncStream

An asynchronous equivalent to Stream.sorted(java.util.Comparator).

Specified by:

sorted in interface AsyncRecordStream<K extends Comparable<K>>

Specified by:

sorted in interface AsyncStream<K extends Comparable<K>>

Parameters:

comparator - comparator used to compare the elements

Returns:

the new stream

peek

AsyncMutableRecordStream<K> peek(Consumer<? super Record<K>> action)

Description copied from interface: AsyncStream

An asynchronous equivalent to Stream.peek(java.util.function.Consumer).

Specified by:

peek in interface AsyncRecordStream<K extends Comparable<K>>

Specified by:

peek in interface AsyncStream<K extends Comparable<K>>

Parameters:

action - action to perform on the elements as they are consumed

Returns:

the new stream

limit

AsyncMutableRecordStream<K> limit(long maxSize)

Description copied from interface: AsyncStream

An asynchronous equivalent to Stream.limit(long).

Specified by:

limit in interface AsyncRecordStream<K extends Comparable<K>>

Specified by:

limit in interface AsyncStream<K extends Comparable<K>>

Parameters:

maxSize - maximum number of elements

Returns:

the new stream

skip

AsyncMutableRecordStream<K> skip(long n)

Description copied from interface: AsyncStream

An asynchronous equivalent to Stream.skip(long).

Specified by:

skip in interface AsyncRecordStream<K extends Comparable<K>>

Specified by:

skip in interface AsyncStream<K extends Comparable<K>>

Parameters:

n - number of leading elements to skip

Returns:

the new stream

sequential

AsyncMutableRecordStream<K> sequential()

Specified by:

sequential in interface AsyncRecordStream<K extends Comparable<K>>

Specified by:

sequential in interface BaseStream<Record<K extends Comparable<K>>,AsyncStream<Record<K extends Comparable<K>>>>

parallel

AsyncMutableRecordStream<K> parallel()

Specified by:

parallel in interface AsyncRecordStream<K extends Comparable<K>>

Specified by:

parallel in interface BaseStream<Record<K extends Comparable<K>>,AsyncStream<Record<K extends Comparable<K>>>>

unordered

AsyncMutableRecordStream<K> unordered()

Specified by:

unordered in interface AsyncRecordStream<K extends Comparable<K>>

Specified by:

unordered in interface BaseStream<Record<K extends Comparable<K>>,AsyncStream<Record<K extends Comparable<K>>>>

onClose

AsyncMutableRecordStream<K> onClose(Runnable closeHandler)

Specified by:

onClose in interface AsyncRecordStream<K extends Comparable<K>>

Specified by:

onClose in interface BaseStream<Record<K extends Comparable<K>>,AsyncStream<Record<K extends Comparable<K>>>>