Package org.sensorhub.api.datastore

Interface AsyncStream<T>

Type Parameters:

T - the type of the stream elements

All Superinterfaces:

AutoCloseable, BaseStream<T,Stream<T>>, Stream<T>

public interface AsyncStream<T>
extends Stream<T>

Interface for asynchronous streams.

This adds asynchronous methods for all terminal operations returning completable futures. When these methods are called the stream pipeline is run asynchronously as data is pushed to the stream.

Default implementations of these new methods simply execute their synchronous counterparts and return the result wrapped in a completed future.

The implementation works by separating the terminal operation from the rest of the stream. The non-terminal part of the stream is then surrounded by 2 (spl)iterators that are controlled by the thread supplying the new data. The terminal operation is also executed by the supplier thread everytime an element comes out of the non-terminal part of the stream.

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.stream.Stream

Stream.Builder<T extends Object>

Method Summary

Modifier and Type	Method	Description
default CompletableFuture<Boolean>	allMatchAsync(Predicate<? super T> predicate)
default CompletableFuture<Boolean>	anyMatchAsync(Predicate<? super T> predicate)
default <R> CompletableFuture<R>	collectAsync(Supplier<R> supplier, BiConsumer<R,? super T> accumulator, BiConsumer<R,R> combiner)
default <R, A> CompletableFuture<R>	collectAsync(Collector<? super T,A,R> collector)
default CompletableFuture<Long>	countAsync()
AsyncStream<T>	distinct()
AsyncStream<T>	filter(Predicate<? super T> predicate)
default CompletableFuture<Optional<T>>	findAnyAsync()
default CompletableFuture<Optional<T>>	findFirstAsync()
<R> AsyncStream<R>	flatMap(Function<? super T,? extends Stream<? extends R>> mapper)
default CompletableFuture<Void>	forEachAsync(Consumer<? super T> action)
default CompletableFuture<Void>	forEachOrderedAsync(Consumer<? super T> action)
AsyncStream<T>	limit(long maxSize)
<R> AsyncStream<R>	map(Function<? super T,? extends R> mapper)
default CompletableFuture<Optional<T>>	maxAsync(Comparator<? super T> comparator)
default CompletableFuture<Optional<T>>	minAsync(Comparator<? super T> comparator)
AsyncStream<T>	parallel()
AsyncStream<T>	peek(Consumer<? super T> action)
default CompletableFuture<Optional<T>>	reduceAsync(BinaryOperator<T> accumulator)
default CompletableFuture<T>	reduceAsync(T identity, BinaryOperator<T> accumulator)
default <U> CompletableFuture<U>	reduceAsync(U identity, BiFunction<U,? super T,U> accumulator, BinaryOperator<U> combiner)
AsyncStream<T>	sequential()
AsyncStream<T>	skip(long n)
AsyncStream<T>	sorted()
AsyncStream<T>	sorted(Comparator<? super T> comparator)
AsyncStream<T>	unordered()

Methods inherited from interface java.util.stream.BaseStream

close, isParallel, iterator, onClose, spliterator

Methods inherited from interface java.util.stream.Stream

allMatch, anyMatch, collect, collect, count, dropWhile, findAny, findFirst, flatMapToDouble, flatMapToInt, flatMapToLong, forEach, forEachOrdered, mapMulti, mapMultiToDouble, mapMultiToInt, mapMultiToLong, mapToDouble, mapToInt, mapToLong, max, min, noneMatch, reduce, reduce, reduce, takeWhile, toArray, toArray, toList

Method Details

allMatchAsync

default CompletableFuture<Boolean> allMatchAsync(Predicate<? super T> predicate)

anyMatchAsync

default CompletableFuture<Boolean> anyMatchAsync(Predicate<? super T> predicate)

collectAsync

default <R,
A> CompletableFuture<R> collectAsync(Collector<? super T,A,R> collector)

collectAsync

default <R> CompletableFuture<R> collectAsync(Supplier<R> supplier,
 BiConsumer<R,? super T> accumulator,
 BiConsumer<R,R> combiner)

countAsync

default CompletableFuture<Long> countAsync()

findAnyAsync

default CompletableFuture<Optional<T>> findAnyAsync()

findFirstAsync

default CompletableFuture<Optional<T>> findFirstAsync()

forEachAsync

default CompletableFuture<Void> forEachAsync(Consumer<? super T> action)

forEachOrderedAsync

default CompletableFuture<Void> forEachOrderedAsync(Consumer<? super T> action)

maxAsync

default CompletableFuture<Optional<T>> maxAsync(Comparator<? super T> comparator)

minAsync

default CompletableFuture<Optional<T>> minAsync(Comparator<? super T> comparator)

reduceAsync

default CompletableFuture<Optional<T>> reduceAsync(BinaryOperator<T> accumulator)

reduceAsync

default CompletableFuture<T> reduceAsync(T identity,
 BinaryOperator<T> accumulator)

reduceAsync

default <U> CompletableFuture<U> reduceAsync(U identity,
 BiFunction<U,? super T,U> accumulator,
 BinaryOperator<U> combiner)

parallel

AsyncStream<T> parallel()

Specified by:

parallel in interface BaseStream<T,Stream<T>>

sequential

AsyncStream<T> sequential()

Specified by:

sequential in interface BaseStream<T,Stream<T>>

unordered

AsyncStream<T> unordered()

Specified by:

unordered in interface BaseStream<T,Stream<T>>

distinct

AsyncStream<T> distinct()

Specified by:

distinct in interface Stream<T>

filter

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

Specified by:

filter in interface Stream<T>

flatMap

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

Specified by:

flatMap in interface Stream<T>

limit

AsyncStream<T> limit(long maxSize)

Specified by:

limit in interface Stream<T>

map

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

Specified by:

map in interface Stream<T>

peek

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

Specified by:

peek in interface Stream<T>

skip

AsyncStream<T> skip(long n)

Specified by:

skip in interface Stream<T>

sorted

AsyncStream<T> sorted()

Specified by:

sorted in interface Stream<T>

sorted

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

Specified by:

sorted in interface Stream<T>