Package | Description |
---|---|
org.eclipse.microprofile.reactive.streams.operators |
Modifier and Type | Method and Description |
---|---|
<T> ProcessorBuilder<T,T> |
ReactiveStreamsFactory.builder()
Create a
ProcessorBuilder . |
static <T> ProcessorBuilder<T,T> |
ReactiveStreams.builder()
Create a
ProcessorBuilder . |
<T,R> ProcessorBuilder<T,R> |
ReactiveStreamsFactory.coupled(org.reactivestreams.Subscriber<? super T> subscriber,
org.reactivestreams.Publisher<? extends R> publisher)
|
static <T,R> ProcessorBuilder<T,R> |
ReactiveStreams.coupled(org.reactivestreams.Subscriber<? super T> subscriber,
org.reactivestreams.Publisher<? extends R> publisher)
|
<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)
|
ProcessorBuilder<T,R> |
ProcessorBuilder.distinct()
Creates a stream consisting of the distinct elements (according to
Object.equals(Object) ) of this stream. |
ProcessorBuilder<T,R> |
ProcessorBuilder.dropWhile(Predicate<? super R> predicate)
Drop the longest prefix of elements from this stream that satisfy the given
predicate . |
ProcessorBuilder<T,R> |
ProcessorBuilder.filter(Predicate<? super R> predicate)
Filter elements emitted by this publisher using the given
Predicate . |
<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> ProcessorBuilder<T,S> |
ProcessorBuilder.flatMapCompletionStage(Function<? super R,? 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> ProcessorBuilder<T,S> |
ProcessorBuilder.flatMapIterable(Function<? super R,? 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> ProcessorBuilder<T,S> |
ProcessorBuilder.flatMapRsPublisher(Function<? super R,? 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,R> ProcessorBuilder<T,R> |
ReactiveStreamsFactory.fromProcessor(org.reactivestreams.Processor<? super T,? extends R> processor)
Create a
ProcessorBuilder from the given Processor . |
static <T,R> ProcessorBuilder<T,R> |
ReactiveStreams.fromProcessor(org.reactivestreams.Processor<? super T,? extends R> processor)
Create a
ProcessorBuilder from the given Processor . |
ProcessorBuilder<T,R> |
ProcessorBuilder.limit(long maxSize)
Truncate this stream, ensuring the stream is no longer than
maxSize elements in length. |
<S> ProcessorBuilder<T,S> |
ProcessorBuilder.map(Function<? super R,? extends S> mapper)
Map the elements emitted by this stream using the
mapper function. |
ProcessorBuilder<T,R> |
ProcessorBuilder.onComplete(Runnable action)
Returns a stream containing all the elements from this stream, additionally performing the provided action when this
stream completes.
|
ProcessorBuilder<T,R> |
ProcessorBuilder.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.
|
ProcessorBuilder<T,R> |
ProcessorBuilder.onErrorResume(Function<Throwable,? extends R> errorHandler)
Returns a stream containing all the elements 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.
|
ProcessorBuilder<T,R> |
ProcessorBuilder.onErrorResumeWithRsPublisher(Function<Throwable,? extends org.reactivestreams.Publisher<? extends R>> errorHandler)
Returns a stream containing all the elements from this stream.
|
ProcessorBuilder<T,R> |
ProcessorBuilder.onTerminate(Runnable action)
Returns a stream containing all the elements from this stream, additionally performing the provided action when this
stream completes or failed.
|
ProcessorBuilder<T,R> |
ProcessorBuilder.peek(Consumer<? super R> consumer)
Returns a stream containing all the elements from this stream, additionally performing the provided action on each
element.
|
ProcessorBuilder<T,R> |
ProcessorBuilder.skip(long n)
Discard the first
n of this stream. |
ProcessorBuilder<T,R> |
ProcessorBuilder.takeWhile(Predicate<? super R> predicate)
Take the longest prefix of elements from this stream that satisfy the given
predicate . |
<S> ProcessorBuilder<T,S> |
ProcessorBuilder.via(org.reactivestreams.Processor<? super R,? extends S> processor)
Connect the outlet of this stream to the given
Processor . |
<S> ProcessorBuilder<T,S> |
ProcessorBuilder.via(ProcessorBuilder<? super R,? extends S> processor)
Connect the outlet of the
Publisher built by this builder to the given ProcessorBuilder . |
Modifier and Type | Method and Description |
---|---|
<S> ProcessorBuilder<T,S> |
ProcessorBuilder.via(ProcessorBuilder<? super R,? extends S> processor)
Connect the outlet of the
Publisher built by this builder to the given ProcessorBuilder . |
<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 . |
<R> ConnectingOperators<R> |
ConnectingOperators.via(ProcessorBuilder<? super T,? extends R> processorBuilder)
Connect the outlet of the
Publisher built by this builder to the given ProcessorBuilder . |
Copyright © 2019 Eclipse Foundation. All rights reserved.