Uses of Class
org.eclipse.microprofile.reactive.streams.PublisherBuilder

Packages that use PublisherBuilder

Package	Description
org.eclipse.microprofile.reactive.streams	MicroProfile Reactive Streams Operators.

Uses of PublisherBuilder in org.eclipse.microprofile.reactive.streams

Methods in org.eclipse.microprofile.reactive.streams that return PublisherBuilder

Modifier and Type	Method and Description
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.
static <T> PublisherBuilder<T>	ReactiveStreams.empty() Create an empty 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,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 publisher.
<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.flatMapPublisher(Function<? super T,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.
static <T> PublisherBuilder<T>	ReactiveStreams.fromIterable(Iterable<? extends T> ts) Create a PublisherBuilder that will emits the elements produced by the passed in Iterable.
static <T> PublisherBuilder<T>	ReactiveStreams.fromPublisher(org.reactivestreams.Publisher<? extends T> publisher) Create a PublisherBuilder from the given Publisher.
static <T> PublisherBuilder<T>	ReactiveStreams.generate(Supplier<? extends T> s) Creates an infinite stream that emits elements supplied by the supplier s.
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 publisher using the mapper function.
static <T> PublisherBuilder<T>	ReactiveStreams.of(T... ts) Create a PublisherBuilder that emits the given elements.
static <T> PublisherBuilder<T>	ReactiveStreams.of(T t) Create a PublisherBuilder that emits a single element.
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,T> errorHandler) Returns a stream containing all the elements from this stream.
PublisherBuilder<T>	PublisherBuilder.onErrorResumeWith(Function<Throwable,PublisherBuilder<T>> errorHandler) Returns a stream containing all the elements from this stream.
<S> PublisherBuilder<S>	PublisherBuilder.onErrorResumeWithPublisher(Function<Throwable,org.reactivestreams.Publisher<? extends S>> 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<T,R> processor) Connect the outlet of this publisher builder to the given ProcessorBuilder graph.
<R> PublisherBuilder<R>	PublisherBuilder.via(ProcessorBuilder<T,R> processor) Connect the outlet of the Publisher built by this builder to the given Processor.

Methods in org.eclipse.microprofile.reactive.streams with parameters of type PublisherBuilder

Modifier and Type	Method and Description
static Graph	GraphAccessor.buildGraphFor(PublisherBuilder<?> publisherBuilder) Build the graph for the given PublisherBuilder.
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.

Method parameters in org.eclipse.microprofile.reactive.streams with type arguments of type PublisherBuilder

Modifier and Type	Method and Description
<S> ProcessorBuilder<T,S>	ProcessorBuilder.flatMap(Function<? super R,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,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,PublisherBuilder<R>> errorHandler) Returns a stream containing all the elements from this stream.
PublisherBuilder<T>	PublisherBuilder.onErrorResumeWith(Function<Throwable,PublisherBuilder<T>> errorHandler) Returns a stream containing all the elements from this stream.