Package | Description |
---|---|
org.eclipse.microprofile.reactive.streams.operators |
Modifier and Type | Interface and Description |
---|---|
interface |
ProcessorBuilder<T,R>
A builder for a
Processor . |
interface |
PublisherBuilder<T>
A builder for a
Publisher . |
Modifier and Type | Method and Description |
---|---|
FilteringOperators<T> |
FilteringOperators.distinct()
Creates a stream consisting of the distinct elements (according to
Object.equals(Object) ) of this stream. |
FilteringOperators<T> |
FilteringOperators.dropWhile(Predicate<? super T> predicate)
Drop the longest prefix of elements from this stream that satisfy the given
predicate . |
FilteringOperators<T> |
FilteringOperators.filter(Predicate<? super T> predicate)
Filter elements emitted by this publisher using the given
Predicate . |
FilteringOperators<T> |
FilteringOperators.limit(long maxSize)
Truncate this stream, ensuring the stream is no longer than
maxSize elements in length. |
FilteringOperators<T> |
FilteringOperators.skip(long n)
Discard the first
n of this stream. |
FilteringOperators<T> |
FilteringOperators.takeWhile(Predicate<? super T> predicate)
Take the longest prefix of elements from this stream that satisfy the given
predicate . |
Copyright © 2019 Eclipse Foundation. All rights reserved.