Package com.terracottatech.store.async

Interface AsyncStream<T>

Type Parameters:

T - the type of the stream elements

All Superinterfaces:

AutoCloseable, BaseStream<T,AsyncStream<T>>

All Known Subinterfaces:

AsyncMutableRecordStream<K>, AsyncRecordStream<K>

public interface AsyncStream<T>
extends BaseStream<T,AsyncStream<T>>

An asynchronous equivalent to Stream.

See Also:

• Stream

Method Summary

Modifier and Type	Method	Description
Operation<Boolean>	allMatch(Predicate<? super T> predicate)	An asynchronous equivalent to Stream.allMatch(java.util.function.Predicate).
Operation<Boolean>	anyMatch(Predicate<? super T> predicate)	An asynchronous equivalent to Stream.anyMatch(java.util.function.Predicate).
<R> Operation<R>	collect(Supplier<R> supplier, BiConsumer<R,? super T> accumulator, BiConsumer<R,R> combiner)	An asynchronous equivalent to Stream.collect(java.util.function.Supplier, java.util.function.BiConsumer, java.util.function.BiConsumer).
<R, A> Operation<R>	collect(Collector<? super T,A,R> collector)	An asynchronous equivalent to Stream.reduce(java.util.function.BinaryOperator).
Operation<Long>	count()	An asynchronous equivalent to Stream.count().
AsyncStream<T>	distinct()	An asynchronous equivalent to Stream.distinct().
AsyncStream<T>	filter(Predicate<? super T> predicate)	An asynchronous equivalent to Stream.filter(java.util.function.Predicate).
Operation<Optional<T>>	findAny()	An asynchronous equivalent to Stream.findAny().
Operation<Optional<T>>	findFirst()	An asynchronous equivalent to Stream.findFirst().
<R> AsyncStream<R>	flatMap(Function<? super T,? extends Stream<? extends R>> mapper)	An asynchronous equivalent to Stream.flatMap(java.util.function.Function).
AsyncDoubleStream	flatMapToDouble(Function<? super T,? extends DoubleStream> mapper)	An asynchronous equivalent to Stream.flatMapToDouble(java.util.function.Function).
AsyncIntStream	flatMapToInt(Function<? super T,? extends IntStream> mapper)	An asynchronous equivalent to Stream.flatMapToInt(java.util.function.Function).
AsyncLongStream	flatMapToLong(Function<? super T,? extends LongStream> mapper)	An asynchronous equivalent to Stream.flatMapToLong(java.util.function.Function).
Operation<Void>	forEach(Consumer<? super T> action)	An asynchronous equivalent to Stream.forEach(java.util.function.Consumer).
Operation<Void>	forEachOrdered(Consumer<? super T> action)	An asynchronous equivalent to Stream.forEachOrdered(java.util.function.Consumer).
AsyncStream<T>	limit(long maxSize)	An asynchronous equivalent to Stream.limit(long).
<R> AsyncStream<R>	map(Function<? super T,? extends R> mapper)	An asynchronous equivalent to Stream.map(java.util.function.Function).
AsyncDoubleStream	mapToDouble(ToDoubleFunction<? super T> mapper)	An asynchronous equivalent to Stream.mapToDouble(java.util.function.ToDoubleFunction).
AsyncIntStream	mapToInt(ToIntFunction<? super T> mapper)	An asynchronous equivalent to Stream.mapToInt(java.util.function.ToIntFunction).
AsyncLongStream	mapToLong(ToLongFunction<? super T> mapper)	An asynchronous equivalent to Stream.mapToLong(java.util.function.ToLongFunction).
Operation<Optional<T>>	max(Comparator<? super T> comparator)	An asynchronous equivalent to Stream.max(java.util.Comparator).
Operation<Optional<T>>	min(Comparator<? super T> comparator)	An asynchronous equivalent to Stream.min(java.util.Comparator).
Operation<Boolean>	noneMatch(Predicate<? super T> predicate)	An asynchronous equivalent to Stream.noneMatch(java.util.function.Predicate).
AsyncStream<T>	peek(Consumer<? super T> action)	An asynchronous equivalent to Stream.peek(java.util.function.Consumer).
Operation<Optional<T>>	reduce(BinaryOperator<T> accumulator)	An asynchronous equivalent to Stream.reduce(java.util.function.BinaryOperator).
Operation<T>	reduce(T identity, BinaryOperator<T> accumulator)	An asynchronous equivalent to Stream.reduce(java.lang.Object, java.util.function.BinaryOperator).
<U> Operation<U>	reduce(U identity, BiFunction<U,? super T,U> accumulator, BinaryOperator<U> combiner)	An asynchronous equivalent to Stream.reduce(java.lang.Object, java.util.function.BiFunction, java.util.function.BinaryOperator).
AsyncStream<T>	skip(long n)	An asynchronous equivalent to Stream.skip(long).
AsyncStream<T>	sorted()	An asynchronous equivalent to Stream.sorted().
AsyncStream<T>	sorted(Comparator<? super T> comparator)	An asynchronous equivalent to Stream.sorted(java.util.Comparator).
Operation<Object[]>	toArray()	An asynchronous equivalent to Stream.toArray().
<A> Operation<A[]>	toArray(IntFunction<A[]> generator)	An asynchronous equivalent to Stream.toArray(java.util.function.IntFunction).

Methods inherited from interface java.util.stream.BaseStream

close, isParallel, iterator, onClose, parallel, sequential, spliterator, unordered

Method Details

filter

AsyncStream<T> filter(Predicate<? super T> predicate)

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

Parameters:

predicate - the inclusion predicate

Returns:

the new stream

map

<R> AsyncStream<R> map(Function<? super T,? extends R> mapper)

An asynchronous equivalent to Stream.map(java.util.function.Function).

Type Parameters:

R - the element type of the new stream

Parameters:

mapper - the element mapping function

Returns:

the new stream

mapToInt

AsyncIntStream mapToInt(ToIntFunction<? super T> mapper)

An asynchronous equivalent to Stream.mapToInt(java.util.function.ToIntFunction).

Parameters:

mapper - the element mapping function

Returns:

the new stream

mapToLong

AsyncLongStream mapToLong(ToLongFunction<? super T> mapper)

An asynchronous equivalent to Stream.mapToLong(java.util.function.ToLongFunction).

Parameters:

mapper - the element mapping function

Returns:

the new stream

mapToDouble

AsyncDoubleStream mapToDouble(ToDoubleFunction<? super T> mapper)

An asynchronous equivalent to Stream.mapToDouble(java.util.function.ToDoubleFunction).

Parameters:

mapper - the element mapping function

Returns:

the new stream

flatMap

<R> AsyncStream<R> flatMap(Function<? super T,? extends Stream<? extends R>> mapper)

An asynchronous equivalent to Stream.flatMap(java.util.function.Function).

Type Parameters:

R - the element type of the new stream

Parameters:

mapper - the element mapping function

Returns:

the new stream

flatMapToInt

AsyncIntStream flatMapToInt(Function<? super T,? extends IntStream> mapper)

An asynchronous equivalent to Stream.flatMapToInt(java.util.function.Function).

Parameters:

mapper - the element mapping function

Returns:

the new stream

flatMapToLong

AsyncLongStream flatMapToLong(Function<? super T,? extends LongStream> mapper)

An asynchronous equivalent to Stream.flatMapToLong(java.util.function.Function).

Parameters:

mapper - the element mapping function

Returns:

the new stream

flatMapToDouble

AsyncDoubleStream flatMapToDouble(Function<? super T,? extends DoubleStream> mapper)

An asynchronous equivalent to Stream.flatMapToDouble(java.util.function.Function).

Parameters:

mapper - the element mapping function

Returns:

the new stream

distinct

AsyncStream<T> distinct()

An asynchronous equivalent to Stream.distinct().

Returns:

the new stream

sorted

AsyncStream<T> sorted()

An asynchronous equivalent to Stream.sorted().

Returns:

the new stream

sorted

AsyncStream<T> sorted(Comparator<? super T> comparator)

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

Parameters:

comparator - comparator used to compare the elements

Returns:

the new stream

peek

AsyncStream<T> peek(Consumer<? super T> action)

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

Parameters:

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

Returns:

the new stream

limit

AsyncStream<T> limit(long maxSize)

An asynchronous equivalent to Stream.limit(long).

Parameters:

maxSize - maximum number of elements

Returns:

the new stream

skip

AsyncStream<T> skip(long n)

An asynchronous equivalent to Stream.skip(long).

Parameters:

n - number of leading elements to skip

Returns:

the new stream

forEach

Operation<Void> forEach(Consumer<? super T> action)

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

Parameters:

action - action to perform on the elements

Returns:

an Operation representing the completion of this action across all elements

forEachOrdered

Operation<Void> forEachOrdered(Consumer<? super T> action)

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

Parameters:

action - action to perform on the elements

Returns:

an Operation representing the completion of this action across all elements

toArray

Operation<Object[]> toArray()

An asynchronous equivalent to Stream.toArray().

Returns:

an Operation representing the conversion of this stream to an array

toArray

<A> Operation<A[]> toArray(IntFunction<A[]> generator)

An asynchronous equivalent to Stream.toArray(java.util.function.IntFunction).

Type Parameters:

A - the element type of the array

Parameters:

generator - a generator function for an array of the desired type and length

Returns:

an Operation representing the conversion of this stream to an array

reduce

Operation<T> reduce(T identity,
 BinaryOperator<T> accumulator)

An asynchronous equivalent to Stream.reduce(java.lang.Object, java.util.function.BinaryOperator).

Parameters:

identity - identity value of the accumulating function

accumulator - the accumulating function

Returns:

an Operation representing the execution of this reduction

reduce

Operation<Optional<T>> reduce(BinaryOperator<T> accumulator)

An asynchronous equivalent to Stream.reduce(java.util.function.BinaryOperator).

Parameters:

accumulator - the accumulating function

Returns:

an Operation representing the execution of this reduction

reduce

<U> Operation<U> reduce(U identity,
 BiFunction<U,? super T,U> accumulator,
 BinaryOperator<U> combiner)

An asynchronous equivalent to Stream.reduce(java.lang.Object, java.util.function.BiFunction, java.util.function.BinaryOperator).

Type Parameters:

U - the type of the result

Parameters:

identity - identity value of the accumulating function

accumulator - the accumulating function

combiner - the combining function

Returns:

an Operation representing the execution of this reduction

collect

<R> Operation<R> collect(Supplier<R> supplier,
 BiConsumer<R,? super T> accumulator,
 BiConsumer<R,R> combiner)

An asynchronous equivalent to Stream.collect(java.util.function.Supplier, java.util.function.BiConsumer, java.util.function.BiConsumer).

Type Parameters:

R - the type of the result

Parameters:

supplier - the result container supplier

accumulator - the accumulating function

combiner - the combining function

Returns:

an Operation representing the execution of this reduction

collect

<R,
A> Operation<R> collect(Collector<? super T,A,R> collector)

An asynchronous equivalent to Stream.reduce(java.util.function.BinaryOperator).

Type Parameters:

R - the type of the result

A - the intermediate accumulation type

Parameters:

collector - the Collector describing the operation

Returns:

an Operation representing the execution of this reduction

min

Operation<Optional<T>> min(Comparator<? super T> comparator)

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

Parameters:

comparator - comparator used to compare elements

Returns:

an Operation representing the calculation of the minimum value

max

Operation<Optional<T>> max(Comparator<? super T> comparator)

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

Parameters:

comparator - comparator used to compare elements

Returns:

an Operation representing the calculation of the maximum value

count

Operation<Long> count()

An asynchronous equivalent to Stream.count().

Returns:

an Operation representing the length of the stream

anyMatch

Operation<Boolean> anyMatch(Predicate<? super T> predicate)

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

Parameters:

predicate - predicate to apply to the elements in the stream

Returns:

an Operation returning true if at least one elements satisfies the predicate

allMatch

Operation<Boolean> allMatch(Predicate<? super T> predicate)

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

Parameters:

predicate - predicate to apply to the elements in the stream

Returns:

an Operation returning true if all the elements satisfy the predicate

noneMatch

Operation<Boolean> noneMatch(Predicate<? super T> predicate)

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

Parameters:

predicate - predicate to apply to the elements in the stream

Returns:

an Operation returning true if none of the elements satisfy the predicate

findFirst

Operation<Optional<T>> findFirst()

An asynchronous equivalent to Stream.findFirst().

Returns:

an Operation returning the first element of the stream

findAny

Operation<Optional<T>> findAny()

An asynchronous equivalent to Stream.findAny().

Returns:

an Operation returning an element of the stream