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

Packages that use SubscriberBuilder

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 SubscriberBuilder in org.eclipse.microprofile.reactive.messaging.spi

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

Modifier and Type	Method	Description
SubscriberBuilder<? extends Message<?>,Void>	OutgoingConnectorFactory.getSubscriberBuilder(Config config)	Creates a channel for the given configuration.

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

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

Modifier and Type	Method	Description
SubscriberBuilder<T,Void>	ProcessorBuilder.cancel()	Cancels the stream as soon as it is run.
<S> SubscriberBuilder<T,S>	ProcessorBuilder.collect(Supplier<S> supplier, BiConsumer<S,? super R> accumulator)	Collect the elements emitted by this stream using a Collector built from the given supplier and accumulator.
<S, A> SubscriberBuilder<T,S>	ProcessorBuilder.collect(Collector<? super R,A,S> collector)	Collect the elements emitted by this stream using the given Collector.
SubscriberBuilder<T,Optional<R>>	ProcessorBuilder.findFirst()	Find the first element emitted by the Publisher, and return it in a CompletionStage.
SubscriberBuilder<T,Void>	ProcessorBuilder.forEach(Consumer<? super R> action)	Performs an action for each element on this stream.
static <T> SubscriberBuilder<T,Void>	ReactiveStreams.fromSubscriber(org.reactivestreams.Subscriber<? super T> subscriber)	Create a SubscriberBuilder from the given Subscriber.
<T> SubscriberBuilder<T,Void>	ReactiveStreamsFactory.fromSubscriber(org.reactivestreams.Subscriber<? super T> subscriber)	Create a SubscriberBuilder from the given Subscriber.
SubscriberBuilder<T,Void>	ProcessorBuilder.ignore()	Ignores each element of this stream.
SubscriberBuilder<T,Optional<R>>	ProcessorBuilder.reduce(BinaryOperator<R> accumulator)	Perform a reduction on the elements of this stream, using the provided accumulation function.
SubscriberBuilder<T,R>	ProcessorBuilder.reduce(R identity, BinaryOperator<R> accumulator)	Perform a reduction on the elements of this stream, using the provided identity value and the accumulation function.
<S> SubscriberBuilder<T,S>	ProcessorBuilder.to(SubscriberBuilder<? super R,? extends S> subscriber)	Connect the outlet of this stream to the given SubscriberBuilder graph.
SubscriberBuilder<T,Void>	ProcessorBuilder.to(org.reactivestreams.Subscriber<? super R> subscriber)	Connect the outlet of the Publisher built by this builder to the given Subscriber.
SubscriberBuilder<T,List<R>>	ProcessorBuilder.toList()	Collect the elements emitted by this stream into a List.

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

Modifier and Type	Method	Description
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.
<R> ProducesResult<R>	ConnectingOperators.to(SubscriberBuilder<? super T,? extends R> subscriberBuilder)	Connect the outlet of this stream to the given SubscriberBuilder graph.
<S> SubscriberBuilder<T,S>	ProcessorBuilder.to(SubscriberBuilder<? super R,? extends S> subscriber)	Connect the outlet of this stream to the given SubscriberBuilder graph.
<R> CompletionRunner<R>	PublisherBuilder.to(SubscriberBuilder<? super T,? extends R> subscriber)	Connect the outlet of this stream to the given SubscriberBuilder graph.