Package com.terracottatech.store.async

Interface AsyncRecordStream<K extends Comparable<K>>

All Superinterfaces:

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

All Known Subinterfaces:

AsyncMutableRecordStream<K>

public interface AsyncRecordStream<K extends Comparable<K>>
extends AsyncStream<Record<K>>

Asynchronous equivalent to RecordStream.

Method Summary

Modifier and Type	Method	Description
AsyncRecordStream<K>	distinct()	An asynchronous equivalent to Stream.distinct().
AsyncRecordStream<K>	explain(Consumer<Object> consumer)	An asynchronous equivalent to RecordStream.explain(Consumer).
AsyncRecordStream<K>	filter(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(Runnable closeHandler)
AsyncRecordStream<K>	parallel()
AsyncRecordStream<K>	peek(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(Comparator<? super Record<K>> comparator)	An asynchronous equivalent to Stream.sorted(java.util.Comparator).
AsyncRecordStream<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

explain

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

An asynchronous equivalent to RecordStream.explain(Consumer).

Parameters:

consumer - the explain consumer

Returns:

the new stream

filter

AsyncRecordStream<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 AsyncStream<K extends Comparable<K>>

Parameters:

predicate - the inclusion predicate

Returns:

the new stream

distinct

AsyncRecordStream<K> distinct()

Description copied from interface: AsyncStream

An asynchronous equivalent to Stream.distinct().

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 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 AsyncStream<K extends Comparable<K>>

Parameters:

comparator - comparator used to compare the elements

Returns:

the new stream

peek

AsyncRecordStream<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 AsyncStream<K extends Comparable<K>>

Parameters:

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

Returns:

the new stream

limit

AsyncRecordStream<K> limit(long maxSize)

Description copied from interface: AsyncStream

An asynchronous equivalent to Stream.limit(long).

Specified by:

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

Parameters:

maxSize - maximum number of elements

Returns:

the new stream

skip

AsyncRecordStream<K> skip(long n)

Description copied from interface: AsyncStream

An asynchronous equivalent to Stream.skip(long).

Specified by:

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

Parameters:

n - number of leading elements to skip

Returns:

the new stream

sequential

AsyncRecordStream<K> sequential()

Specified by:

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

parallel

AsyncRecordStream<K> parallel()

Specified by:

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

unordered

AsyncRecordStream<K> unordered()

Specified by:

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

onClose

AsyncRecordStream<K> onClose(Runnable closeHandler)

Specified by:

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