Package | Description |
---|---|
org.eclipse.microprofile.reactive.streams.operators |
Modifier and Type | Method and Description |
---|---|
<T> PublisherBuilder<T> |
ReactiveStreamsFactory.concat(PublisherBuilder<? extends T> a,
PublisherBuilder<? extends T> b)
Concatenates two publishers.
|
static <T> PublisherBuilder<T> |
ReactiveStreams.concat(PublisherBuilder<? extends T> a,
PublisherBuilder<? extends T> b)
Concatenates two publishers.
|
PublisherBuilder<T> |
PublisherBuilder.distinct()
Creates a stream consisting of the distinct elements (according to
Object.equals(Object) ) of this stream. |
PublisherBuilder<T> |
PublisherBuilder.dropWhile(Predicate<? super T> predicate)
Drop the longest prefix of elements from this stream that satisfy the given
predicate . |
<T> PublisherBuilder<T> |
ReactiveStreamsFactory.empty()
Create an empty
PublisherBuilder . |
static <T> PublisherBuilder<T> |
ReactiveStreams.empty()
Create an empty
PublisherBuilder . |
<T> PublisherBuilder<T> |
ReactiveStreamsFactory.failed(Throwable t)
Create a failed
PublisherBuilder . |
static <T> PublisherBuilder<T> |
ReactiveStreams.failed(Throwable t)
Create a failed
PublisherBuilder . |
PublisherBuilder<T> |
PublisherBuilder.filter(Predicate<? super T> predicate)
Filter elements emitted by this publisher using the given
Predicate . |
<S> PublisherBuilder<S> |
PublisherBuilder.flatMap(Function<? super T,? extends PublisherBuilder<? extends S>> mapper)
Map the elements to publishers, and flatten so that the elements emitted by publishers produced by the
mapper function are emitted from this stream. |
<S> PublisherBuilder<S> |
PublisherBuilder.flatMapCompletionStage(Function<? super T,? extends CompletionStage<? extends S>> mapper)
Map the elements to
CompletionStage , and flatten so that the elements the values redeemed by each
CompletionStage are emitted from this stream. |
<S> PublisherBuilder<S> |
PublisherBuilder.flatMapIterable(Function<? super T,? extends Iterable<? extends S>> mapper)
Map the elements to
Iterable 's, and flatten so that the elements contained in each iterable are
emitted by this stream. |
<S> PublisherBuilder<S> |
PublisherBuilder.flatMapRsPublisher(Function<? super T,? extends org.reactivestreams.Publisher<? extends S>> mapper)
Map the elements to publishers, and flatten so that the elements emitted by publishers produced by the
mapper function are emitted from this stream. |
<T> PublisherBuilder<T> |
ReactiveStreamsFactory.fromCompletionStage(CompletionStage<? extends T> completionStage)
Creates a publisher from a
CompletionStage . |
static <T> PublisherBuilder<T> |
ReactiveStreams.fromCompletionStage(CompletionStage<? extends T> completionStage)
Creates a publisher from a
CompletionStage . |
<T> PublisherBuilder<T> |
ReactiveStreamsFactory.fromCompletionStageNullable(CompletionStage<? extends T> completionStage)
Creates a publisher from a
CompletionStage . |
static <T> PublisherBuilder<T> |
ReactiveStreams.fromCompletionStageNullable(CompletionStage<? extends T> completionStage)
Creates a publisher from a
CompletionStage . |
<T> PublisherBuilder<T> |
ReactiveStreamsFactory.fromIterable(Iterable<? extends T> ts)
Create a
PublisherBuilder that will emits the elements produced by the passed in Iterable . |
static <T> PublisherBuilder<T> |
ReactiveStreams.fromIterable(Iterable<? extends T> ts)
Create a
PublisherBuilder that will emits the elements produced by the passed in Iterable . |
<T> PublisherBuilder<T> |
ReactiveStreamsFactory.fromPublisher(org.reactivestreams.Publisher<? extends T> publisher)
Create a
PublisherBuilder from the given Publisher . |
static <T> PublisherBuilder<T> |
ReactiveStreams.fromPublisher(org.reactivestreams.Publisher<? extends T> publisher)
Create a
PublisherBuilder from the given Publisher . |
<T> PublisherBuilder<T> |
ReactiveStreamsFactory.generate(Supplier<? extends T> s)
Creates an infinite stream that emits elements supplied by the supplier
s . |
static <T> PublisherBuilder<T> |
ReactiveStreams.generate(Supplier<? extends T> s)
Creates an infinite stream that emits elements supplied by the supplier
s . |
<T> PublisherBuilder<T> |
ReactiveStreamsFactory.iterate(T seed,
UnaryOperator<T> f)
Creates an infinite stream produced by the iterative application of the function
f to an initial element
seed consisting of seed , f(seed) , f(f(seed)) , etc. |
static <T> PublisherBuilder<T> |
ReactiveStreams.iterate(T seed,
UnaryOperator<T> f)
Creates an infinite stream produced by the iterative application of the function
f to an initial element
seed consisting of seed , f(seed) , f(f(seed)) , etc. |
PublisherBuilder<T> |
PublisherBuilder.limit(long maxSize)
Truncate this stream, ensuring the stream is no longer than
maxSize elements in length. |
<R> PublisherBuilder<R> |
PublisherBuilder.map(Function<? super T,? extends R> mapper)
Map the elements emitted by this stream using the
mapper function. |
<T> PublisherBuilder<T> |
ReactiveStreamsFactory.of(T... ts)
Create a
PublisherBuilder that emits the given elements. |
static <T> PublisherBuilder<T> |
ReactiveStreams.of(T... ts)
Create a
PublisherBuilder that emits the given elements. |
<T> PublisherBuilder<T> |
ReactiveStreamsFactory.of(T t)
Create a
PublisherBuilder that emits a single element. |
static <T> PublisherBuilder<T> |
ReactiveStreams.of(T t)
Create a
PublisherBuilder that emits a single element. |
<T> PublisherBuilder<T> |
ReactiveStreamsFactory.ofNullable(T t)
Create a
PublisherBuilder that will emit a single element if t is not null, otherwise will be
empty. |
static <T> PublisherBuilder<T> |
ReactiveStreams.ofNullable(T t)
Create a
PublisherBuilder that will emit a single element if t is not null, otherwise will be
empty. |
PublisherBuilder<T> |
PublisherBuilder.onComplete(Runnable action)
Returns a stream containing all the elements from this stream, additionally performing the provided action when this
stream completes.
|
PublisherBuilder<T> |
PublisherBuilder.onError(Consumer<Throwable> errorHandler)
Returns a stream containing all the elements from this stream, additionally performing the provided action if this
stream conveys an error.
|
PublisherBuilder<T> |
PublisherBuilder.onErrorResume(Function<Throwable,? extends T> errorHandler)
Returns a stream containing all the elements from this stream.
|
PublisherBuilder<T> |
PublisherBuilder.onErrorResumeWith(Function<Throwable,? extends PublisherBuilder<? extends T>> errorHandler)
Returns a stream containing all the elements from this stream.
|
PublisherBuilder<T> |
PublisherBuilder.onErrorResumeWithRsPublisher(Function<Throwable,? extends org.reactivestreams.Publisher<? extends T>> errorHandler)
Returns a stream containing all the elements from this stream.
|
PublisherBuilder<T> |
PublisherBuilder.onTerminate(Runnable action)
Returns a stream containing all the elements from this stream, additionally performing the provided action when this
stream completes or failed.
|
PublisherBuilder<T> |
PublisherBuilder.peek(Consumer<? super T> consumer)
Returns a stream containing all the elements from this stream, additionally performing the provided action on each
element.
|
PublisherBuilder<T> |
PublisherBuilder.skip(long n)
Discard the first
n of this stream. |
PublisherBuilder<T> |
PublisherBuilder.takeWhile(Predicate<? super T> predicate)
Take the longest prefix of elements from this stream that satisfy the given
predicate . |
<R> PublisherBuilder<R> |
PublisherBuilder.via(org.reactivestreams.Processor<? super T,? extends R> processor)
Connect the outlet of this stream to the given
Processor . |
<R> PublisherBuilder<R> |
PublisherBuilder.via(ProcessorBuilder<? super T,? extends R> processor)
Connect the outlet of the
Publisher built by this builder to the given ProcessorBuilder . |
Modifier and Type | Method and Description |
---|---|
<T> PublisherBuilder<T> |
ReactiveStreamsFactory.concat(PublisherBuilder<? extends T> a,
PublisherBuilder<? extends T> b)
Concatenates two publishers.
|
<T> PublisherBuilder<T> |
ReactiveStreamsFactory.concat(PublisherBuilder<? extends T> a,
PublisherBuilder<? extends T> b)
Concatenates two publishers.
|
static <T> PublisherBuilder<T> |
ReactiveStreams.concat(PublisherBuilder<? extends T> a,
PublisherBuilder<? extends T> b)
Concatenates two publishers.
|
static <T> PublisherBuilder<T> |
ReactiveStreams.concat(PublisherBuilder<? extends T> a,
PublisherBuilder<? extends T> b)
Concatenates two publishers.
|
<T,R> ProcessorBuilder<T,R> |
ReactiveStreamsFactory.coupled(SubscriberBuilder<? super T,?> subscriber,
PublisherBuilder<? extends R> publisher)
|
static <T,R> ProcessorBuilder<T,R> |
ReactiveStreams.coupled(SubscriberBuilder<? super T,?> subscriber,
PublisherBuilder<? extends R> publisher)
|
Modifier and Type | Method and Description |
---|---|
<S> ProcessorBuilder<T,S> |
ProcessorBuilder.flatMap(Function<? super R,? extends PublisherBuilder<? extends S>> mapper)
Map the elements to publishers, and flatten so that the elements emitted by publishers produced by the
mapper function are emitted from this stream. |
<S> TransformingOperators<S> |
TransformingOperators.flatMap(Function<? super T,? extends PublisherBuilder<? extends S>> mapper)
Map the elements to publishers, and flatten so that the elements emitted by publishers produced by the
mapper function are emitted from this stream. |
<S> PublisherBuilder<S> |
PublisherBuilder.flatMap(Function<? super T,? extends PublisherBuilder<? extends S>> mapper)
Map the elements to publishers, and flatten so that the elements emitted by publishers produced by the
mapper function are emitted from this stream. |
ProcessorBuilder<T,R> |
ProcessorBuilder.onErrorResumeWith(Function<Throwable,? extends PublisherBuilder<? extends R>> errorHandler)
Returns a stream containing all the elements from this stream.
|
PublisherBuilder<T> |
PublisherBuilder.onErrorResumeWith(Function<Throwable,? extends PublisherBuilder<? extends T>> errorHandler)
Returns a stream containing all the elements from this stream.
|
ErrorHandlingOperators<T> |
ErrorHandlingOperators.onErrorResumeWith(Function<Throwable,? extends PublisherBuilder<? extends T>> errorHandler)
Returns a stream containing all the elements from this stream.
|
Copyright © 2019 Eclipse Foundation. All rights reserved.