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

Packages that use PublisherBuilder

Package	Description
org.eclipse.microprofile.reactive.messaging.spi	The MicroProfile Reactive Messaging API Connector SPI
org.eclipse.microprofile.reactive.streams.operators	MicroProfile Reactive Streams Operators.

Uses of PublisherBuilder in org.eclipse.microprofile.reactive.messaging.spi

Methods in org.eclipse.microprofile.reactive.messaging.spi that return PublisherBuilder

Modifier and Type	Method	Description
PublisherBuilder<? extends Message<?>>	IncomingConnectorFactory.getPublisherBuilder(Config config)	Creates a channel for the given configuration.

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

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

Modifier and Type	Method	Description
static <T> PublisherBuilder<T>	ReactiveStreams.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.
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.
<T> PublisherBuilder<T>	ReactiveStreamsFactory.empty()	Create an empty PublisherBuilder.
static <T> PublisherBuilder<T>	ReactiveStreams.failed(Throwable t)	Create a failed PublisherBuilder.
<T> PublisherBuilder<T>	ReactiveStreamsFactory.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.
static <T> PublisherBuilder<T>	ReactiveStreams.fromCompletionStage(CompletionStage<? extends T> completionStage)	Creates a publisher from a CompletionStage.
<T> PublisherBuilder<T>	ReactiveStreamsFactory.fromCompletionStage(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.fromCompletionStageNullable(CompletionStage<? extends T> completionStage)	Creates a publisher from a CompletionStage.
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.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.
<T> PublisherBuilder<T>	ReactiveStreamsFactory.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.
<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.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.
<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.
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.
static <T> PublisherBuilder<T>	ReactiveStreams.of(T t)	Create a PublisherBuilder that emits a single element.
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.
<T> PublisherBuilder<T>	ReactiveStreamsFactory.of(T... ts)	Create a PublisherBuilder that emits the given elements.
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.
<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.
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(ProcessorBuilder<? super T,? extends R> processor)	Connect the outlet of the Publisher built by this builder to the given ProcessorBuilder.
<R> PublisherBuilder<R>	PublisherBuilder.via(org.reactivestreams.Processor<? super T,? extends R> processor)	Connect the outlet of this stream to the given Processor.

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

Modifier and Type	Method	Description
static <T> PublisherBuilder<T>	ReactiveStreams.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, R> ProcessorBuilder<T,R>	ReactiveStreams.coupled(SubscriberBuilder<? super T,?> subscriber, PublisherBuilder<? extends R> publisher)	Creates a ProcessorBuilder by coupling a SubscriberBuilder to a PublisherBuilder.
<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.

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

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