org.eclipse.microprofile.reactive.streams.operators

Interface FilteringOperators<T>

Type Parameters:

T - The type of the elements that the stream emits.

All Known Subinterfaces:

ProcessorBuilder<T,R>, PublisherBuilder<T>

public interface FilteringOperators<T>

Operations for transforming a stream.

The documentation for each operator uses marble diagrams to visualize how the operator functions. Each element flowing in and out of the stream is represented as a coloured marble that has a value, with the operator applying some transformation or some side effect, termination and error signals potentially being passed, and for operators that subscribe to the stream, an output value being redeemed at the end.

Below is an example diagram labelling all the parts of the stream.

Method Summary

Modifier and Type	Method and Description
FilteringOperators<T>	distinct() Creates a stream consisting of the distinct elements (according to Object.equals(Object)) of this stream.
FilteringOperators<T>	dropWhile(Predicate<? super T> predicate) Drop the longest prefix of elements from this stream that satisfy the given predicate.
FilteringOperators<T>	filter(Predicate<? super T> predicate) Filter elements emitted by this publisher using the given Predicate.
FilteringOperators<T>	limit(long maxSize) Truncate this stream, ensuring the stream is no longer than maxSize elements in length.
FilteringOperators<T>	skip(long n) Discard the first n of this stream.
FilteringOperators<T>	takeWhile(Predicate<? super T> predicate) Take the longest prefix of elements from this stream that satisfy the given predicate.

Method Detail

filter

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

Filter elements emitted by this publisher using the given Predicate.

Any elements that return true when passed to the Predicate will be emitted, all other elements will be dropped.

Parameters:

predicate - The predicate to apply to each element.

Returns:

A new stream builder.

distinct

FilteringOperators<T> distinct()

Creates a stream consisting of the distinct elements (according to Object.equals(Object)) of this stream.

Returns:

A new stream builder emitting the distinct elements from this stream.

limit

FilteringOperators<T> limit(long maxSize)

Truncate this stream, ensuring the stream is no longer than maxSize elements in length.

If maxSize is reached, the stream will be completed, and upstream will be cancelled. Completion of the stream will occur immediately when the element that satisfies the maxSize is received.

Parameters:

maxSize - The maximum size of the returned stream.

Returns:

A new stream builder.

Throws:

IllegalArgumentException - If maxSize is less than zero.

skip

FilteringOperators<T> skip(long n)

Discard the first n of this stream. If this stream contains fewer than n elements, this stream will effectively be an empty stream.

Parameters:

n - The number of elements to discard.

Returns:

A new stream builder.

Throws:

IllegalArgumentException - If n is less than zero.

takeWhile

FilteringOperators<T> takeWhile(Predicate<? super T> predicate)

Take the longest prefix of elements from this stream that satisfy the given predicate.

When the predicate returns false, the stream will be completed, and upstream will be cancelled.

Parameters:

predicate - The predicate.

Returns:

A new stream builder.

dropWhile

FilteringOperators<T> dropWhile(Predicate<? super T> predicate)

Drop the longest prefix of elements from this stream that satisfy the given predicate.

As long as the predicate returns true, no elements will be emitted from this stream. Once the first element is encountered for which the predicate returns false, all subsequent elements will be emitted, and the predicate will no longer be invoked.

Parameters:

predicate - The predicate.

Returns:

A new stream builder.