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

Packages that use CompletionRunner

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

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

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

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

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

Modifier and Type	Method and Description
static Graph	GraphAccessor.buildGraphFor(CompletionRunner<?> completionRunner) Build the graph for the given CompletionRunner.