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

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

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

Methods in org.eclipse.microprofile.reactive.streams.operators that return ProcessorBuilder
`<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)` Creates a `ProcessorBuilder` by coupling a `Subscriber` to a `Publisher`.
`static <T,R> ProcessorBuilder<T,R>` ReactiveStreams.`coupled(org.reactivestreams.Subscriber<? super T> subscriber, org.reactivestreams.Publisher<? extends R> publisher)` Creates a `ProcessorBuilder` by coupling a `Subscriber` to a `Publisher`.
`<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`.
`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`.

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