## Uses of Interface
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder

Packages that use PublisherBuilder
org.eclipse.microprofile.reactive.streams.operators: MicroProfile Reactive Streams Operators.

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

Methods in org.eclipse.microprofile.reactive.streams.operators that return PublisherBuilder
`<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`.

Methods in org.eclipse.microprofile.reactive.streams.operators with parameters of type PublisherBuilder
`<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)` Creates a `ProcessorBuilder` by coupling a `SubscriberBuilder` to a `PublisherBuilder`.
`static <T,R> ProcessorBuilder<T,R>` ReactiveStreams.`coupled(SubscriberBuilder<? super T,?> subscriber, PublisherBuilder<? extends R> publisher)` Creates a `ProcessorBuilder` by coupling a `SubscriberBuilder` to a `PublisherBuilder`.

Method parameters in org.eclipse.microprofile.reactive.streams.operators with type arguments of type PublisherBuilder
`<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.