Index (MicroProfile Reactive Streams Operators 1.0-RC2 API)

B C D E F G I L M O P R S T V

B

build() - Method in interface org.eclipse.microprofile.reactive.streams.SubscriberBuilder: Build this stream, using the first ReactiveStreamsEngine found by the ServiceLoader.
build(ReactiveStreamsEngine) - Method in interface org.eclipse.microprofile.reactive.streams.SubscriberBuilder: Build this stream, using the supplied ReactiveStreamsEngine.
builder() - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreams: Create a ProcessorBuilder.
builder() - Method in interface org.eclipse.microprofile.reactive.streams.ReactiveStreamsFactory: Create a ProcessorBuilder.
buildRs() - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Build this stream, using the first ReactiveStreamsEngine found by the ServiceLoader.
buildRs(ReactiveStreamsEngine) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Build this stream, using the supplied ReactiveStreamsEngine.
buildRs() - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Build this stream, using the first ReactiveStreamsEngine found by the ServiceLoader.
buildRs(ReactiveStreamsEngine) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Build this stream, using the supplied ReactiveStreamsEngine.

C

cancel() - Method in interface org.eclipse.microprofile.reactive.streams.ConsumingOperators: Cancels the stream as soon as it starts.
cancel() - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Cancels the stream as soon as it starts.
cancel() - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Cancels the stream as soon as it starts.
collect(Collector<? super T, A, R>) - Method in interface org.eclipse.microprofile.reactive.streams.ConsumingOperators: Collect the elements emitted by this stream using the given Collector.
collect(Supplier<R>, BiConsumer<R, ? super T>) - Method in interface org.eclipse.microprofile.reactive.streams.ConsumingOperators: Collect the elements emitted by this stream using a Collector built from the given supplier and accumulator.
collect(Collector<? super R, A, S>) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Collect the elements emitted by this stream using the given Collector.
collect(Supplier<S>, BiConsumer<S, ? super R>) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Collect the elements emitted by this stream using a Collector built from the given supplier and accumulator.
collect(Collector<? super T, A, R>) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Collect the elements emitted by this stream using the given Collector.
collect(Supplier<R>, BiConsumer<R, ? super T>) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Collect the elements emitted by this stream using a Collector built from the given supplier and accumulator.
CompletionRunner<T> - Interface in org.eclipse.microprofile.reactive.streams: A builder for a closed reactive streams graph.
CompletionSubscriber<T,R> - Interface in org.eclipse.microprofile.reactive.streams: A subscriber that redeems a completion stage when it completes.
concat(PublisherBuilder<? extends T>, PublisherBuilder<? extends T>) - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreams: Concatenates two publishers.
concat(PublisherBuilder<? extends T>, PublisherBuilder<? extends T>) - Method in interface org.eclipse.microprofile.reactive.streams.ReactiveStreamsFactory: Concatenates two publishers.
ConnectingOperators<T> - Interface in org.eclipse.microprofile.reactive.streams: Operators for connecting different graphs together.
ConsumingOperators<T> - Interface in org.eclipse.microprofile.reactive.streams: Operators for completing a stream.

D

distinct() - Method in interface org.eclipse.microprofile.reactive.streams.FilteringOperators: Creates a stream consisting of the distinct elements (according to Object.equals(Object)) of this stream.
distinct() - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Creates a stream consisting of the distinct elements (according to Object.equals(Object)) of this stream.
distinct() - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Creates a stream consisting of the distinct elements (according to Object.equals(Object)) of this stream.
dropWhile(Predicate<? super T>) - Method in interface org.eclipse.microprofile.reactive.streams.FilteringOperators: Drop the longest prefix of elements from this stream that satisfy the given predicate.
dropWhile(Predicate<? super R>) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Drop the longest prefix of elements from this stream that satisfy the given predicate.
dropWhile(Predicate<? super T>) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Drop the longest prefix of elements from this stream that satisfy the given predicate.

E

empty() - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreams: Create an empty PublisherBuilder.
empty() - Method in interface org.eclipse.microprofile.reactive.streams.ReactiveStreamsFactory: Create an empty PublisherBuilder.
ErrorHandlingOperators<T> - Interface in org.eclipse.microprofile.reactive.streams: Operators for handling errors in streams.

F

failed(Throwable) - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreams: Create a failed PublisherBuilder.
failed(Throwable) - Method in interface org.eclipse.microprofile.reactive.streams.ReactiveStreamsFactory: Create a failed PublisherBuilder.
filter(Predicate<? super T>) - Method in interface org.eclipse.microprofile.reactive.streams.FilteringOperators: Filter elements emitted by this publisher using the given Predicate.
filter(Predicate<? super R>) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Filter elements emitted by this publisher using the given Predicate.
filter(Predicate<? super T>) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Filter elements emitted by this publisher using the given Predicate.
FilteringOperators<T> - Interface in org.eclipse.microprofile.reactive.streams: Operations for transforming a stream.
findFirst() - Method in interface org.eclipse.microprofile.reactive.streams.ConsumingOperators: Find the first element emitted by the Publisher, and return it in a CompletionStage.
findFirst() - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Find the first element emitted by the Publisher, and return it in a CompletionStage.
findFirst() - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Find the first element emitted by the Publisher, and return it in a CompletionStage.
flatMap(Function<? super R, ? extends PublisherBuilder<? extends S>>) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Map the elements to publishers, and flatten so that the elements emitted by publishers produced by the mapper function are emitted from this stream.
flatMap(Function<? super T, ? extends PublisherBuilder<? extends S>>) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Map the elements to publishers, and flatten so that the elements emitted by publishers produced by the mapper function are emitted from this stream.
flatMap(Function<? super T, ? extends PublisherBuilder<? extends S>>) - Method in interface org.eclipse.microprofile.reactive.streams.TransformingOperators: Map the elements to publishers, and flatten so that the elements emitted by publishers produced by the mapper function are emitted from this stream.
flatMapCompletionStage(Function<? super R, ? extends CompletionStage<? extends S>>) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Map the elements to CompletionStage, and flatten so that the elements the values redeemed by each CompletionStage are emitted from this stream.
flatMapCompletionStage(Function<? super T, ? extends CompletionStage<? extends S>>) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Map the elements to CompletionStage, and flatten so that the elements the values redeemed by each CompletionStage are emitted from this stream.
flatMapCompletionStage(Function<? super T, ? extends CompletionStage<? extends S>>) - Method in interface org.eclipse.microprofile.reactive.streams.TransformingOperators: Map the elements to CompletionStage, and flatten so that the elements the values redeemed by each CompletionStage are emitted from this stream.
flatMapIterable(Function<? super R, ? extends Iterable<? extends S>>) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Map the elements to Iterable's, and flatten so that the elements contained in each iterable are emitted by this stream.
flatMapIterable(Function<? super T, ? extends Iterable<? extends S>>) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Map the elements to Iterable's, and flatten so that the elements contained in each iterable are emitted by this stream.
flatMapIterable(Function<? super T, ? extends Iterable<? extends S>>) - Method in interface org.eclipse.microprofile.reactive.streams.TransformingOperators: Map the elements to Iterable's, and flatten so that the elements contained in each iterable are emitted by this stream.
flatMapRsPublisher(Function<? super R, ? extends Publisher<? extends S>>) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Map the elements to publishers, and flatten so that the elements emitted by publishers produced by the mapper function are emitted from this stream.
flatMapRsPublisher(Function<? super T, ? extends Publisher<? extends S>>) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Map the elements to publishers, and flatten so that the elements emitted by publishers produced by the mapper function are emitted from this stream.
flatMapRsPublisher(Function<? super T, ? extends Publisher<? extends S>>) - Method in interface org.eclipse.microprofile.reactive.streams.TransformingOperators: Map the elements to publishers, and flatten so that the elements emitted by publishers produced by the mapper function are emitted from this stream.
forEach(Consumer<? super T>) - Method in interface org.eclipse.microprofile.reactive.streams.ConsumingOperators: Performs an action for each element on this stream.
forEach(Consumer<? super R>) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Performs an action for each element on this stream.
forEach(Consumer<? super T>) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Performs an action for each element on this stream.
fromCompletionStage(CompletionStage<? extends T>) - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreams: Creates a publisher from a CompletionStage.
fromCompletionStage(CompletionStage<? extends T>) - Method in interface org.eclipse.microprofile.reactive.streams.ReactiveStreamsFactory: Creates a publisher from a CompletionStage.
fromCompletionStageNullable(CompletionStage<? extends T>) - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreams: Creates a publisher from a CompletionStage.
fromCompletionStageNullable(CompletionStage<? extends T>) - Method in interface org.eclipse.microprofile.reactive.streams.ReactiveStreamsFactory: Creates a publisher from a CompletionStage.
fromIterable(Iterable<? extends T>) - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreams: Create a PublisherBuilder that will emits the elements produced by the passed in Iterable.
fromIterable(Iterable<? extends T>) - Method in interface org.eclipse.microprofile.reactive.streams.ReactiveStreamsFactory: Create a PublisherBuilder that will emits the elements produced by the passed in Iterable.
fromProcessor(Processor<? super T, ? extends R>) - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreams: Create a ProcessorBuilder from the given Processor.
fromProcessor(Processor<? super T, ? extends R>) - Method in interface org.eclipse.microprofile.reactive.streams.ReactiveStreamsFactory: Create a ProcessorBuilder from the given Processor.
fromPublisher(Publisher<? extends T>) - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreams: Create a PublisherBuilder from the given Publisher.
fromPublisher(Publisher<? extends T>) - Method in interface org.eclipse.microprofile.reactive.streams.ReactiveStreamsFactory: Create a PublisherBuilder from the given Publisher.
fromSubscriber(Subscriber<? extends T>) - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreams: Create a SubscriberBuilder from the given Subscriber.
fromSubscriber(Subscriber<? extends T>) - Method in interface org.eclipse.microprofile.reactive.streams.ReactiveStreamsFactory: Create a SubscriberBuilder from the given Subscriber.

G

generate(Supplier<? extends T>) - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreams: Creates an infinite stream that emits elements supplied by the supplier s.
generate(Supplier<? extends T>) - Method in interface org.eclipse.microprofile.reactive.streams.ReactiveStreamsFactory: Creates an infinite stream that emits elements supplied by the supplier s.
getCompletion() - Method in interface org.eclipse.microprofile.reactive.streams.CompletionSubscriber: Get the completion stage.

I

ignore() - Method in interface org.eclipse.microprofile.reactive.streams.ConsumingOperators: Ignores each element of this stream.
ignore() - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Ignores each element of this stream.
ignore() - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Ignores each element of this stream.
instance() - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreamsFactoryResolver: Creates a ReactiveStreamsFactory object Only used internally from within ReactiveStreams
iterate(T, UnaryOperator<T>) - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreams: 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.
iterate(T, UnaryOperator<T>) - Method in interface org.eclipse.microprofile.reactive.streams.ReactiveStreamsFactory: 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.

L

limit(long) - Method in interface org.eclipse.microprofile.reactive.streams.FilteringOperators: Truncate this stream, ensuring the stream is no longer than maxSize elements in length.
limit(long) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Truncate this stream, ensuring the stream is no longer than maxSize elements in length.
limit(long) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Truncate this stream, ensuring the stream is no longer than maxSize elements in length.

M

map(Function<? super R, ? extends S>) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Map the elements emitted by this stream using the mapper function.
map(Function<? super T, ? extends R>) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Map the elements emitted by this stream using the mapper function.
map(Function<? super T, ? extends R>) - Method in interface org.eclipse.microprofile.reactive.streams.TransformingOperators: Map the elements emitted by this stream using the mapper function.

O

of(Subscriber<T>, CompletionStage<R>) - Static method in interface org.eclipse.microprofile.reactive.streams.CompletionSubscriber: Create a CompletionSubscriber by combining the given subscriber and completion stage.
of(T) - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreams: Create a PublisherBuilder that emits a single element.
of(T...) - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreams: Create a PublisherBuilder that emits the given elements.
of(T) - Method in interface org.eclipse.microprofile.reactive.streams.ReactiveStreamsFactory: Create a PublisherBuilder that emits a single element.
of(T...) - Method in interface org.eclipse.microprofile.reactive.streams.ReactiveStreamsFactory: Create a PublisherBuilder that emits the given elements.
ofNullable(T) - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreams: Create a PublisherBuilder that will emit a single element if t is not null, otherwise will be empty.
ofNullable(T) - Method in interface org.eclipse.microprofile.reactive.streams.ReactiveStreamsFactory: Create a PublisherBuilder that will emit a single element if t is not null, otherwise will be empty.
onComplete(Runnable) - Method in interface org.eclipse.microprofile.reactive.streams.PeekingOperators: Returns a stream containing all the elements from this stream, additionally performing the provided action when this stream completes.
onComplete(Runnable) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Returns a stream containing all the elements from this stream, additionally performing the provided action when this stream completes.
onComplete(Runnable) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Returns a stream containing all the elements from this stream, additionally performing the provided action when this stream completes.
onError(Consumer<Throwable>) - Method in interface org.eclipse.microprofile.reactive.streams.PeekingOperators: Returns a stream containing all the elements from this stream, additionally performing the provided action if this stream conveys an error.
onError(Consumer<Throwable>) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Returns a stream containing all the elements from this stream, additionally performing the provided action if this stream conveys an error.
onError(Consumer<Throwable>) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Returns a stream containing all the elements from this stream, additionally performing the provided action if this stream conveys an error.
onErrorResume(Function<Throwable, ? extends T>) - Method in interface org.eclipse.microprofile.reactive.streams.ErrorHandlingOperators: Returns a stream containing all the elements from this stream.
onErrorResume(Function<Throwable, ? extends R>) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Returns a stream containing all the elements from this stream.
onErrorResume(Function<Throwable, ? extends T>) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Returns a stream containing all the elements from this stream.
onErrorResumeWith(Function<Throwable, ? extends PublisherBuilder<? extends T>>) - Method in interface org.eclipse.microprofile.reactive.streams.ErrorHandlingOperators: Returns a stream containing all the elements from this stream.
onErrorResumeWith(Function<Throwable, ? extends PublisherBuilder<? extends R>>) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Returns a stream containing all the elements from this stream.
onErrorResumeWith(Function<Throwable, ? extends PublisherBuilder<? extends T>>) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Returns a stream containing all the elements from this stream.
onErrorResumeWithRsPublisher(Function<Throwable, ? extends Publisher<? extends T>>) - Method in interface org.eclipse.microprofile.reactive.streams.ErrorHandlingOperators: Returns a stream containing all the elements from this stream.
onErrorResumeWithRsPublisher(Function<Throwable, ? extends Publisher<? extends R>>) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Returns a stream containing all the elements from this stream.
onErrorResumeWithRsPublisher(Function<Throwable, ? extends Publisher<? extends T>>) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Returns a stream containing all the elements from this stream.
onTerminate(Runnable) - Method in interface org.eclipse.microprofile.reactive.streams.PeekingOperators: Returns a stream containing all the elements from this stream, additionally performing the provided action when this stream completes or failed.
onTerminate(Runnable) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Returns a stream containing all the elements from this stream, additionally performing the provided action when this stream completes or failed.
onTerminate(Runnable) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Returns a stream containing all the elements from this stream, additionally performing the provided action when this stream completes or failed.
org.eclipse.microprofile.reactive.streams - package org.eclipse.microprofile.reactive.streams: MicroProfile Reactive Streams Operators.

P

peek(Consumer<? super T>) - Method in interface org.eclipse.microprofile.reactive.streams.PeekingOperators: Returns a stream containing all the elements from this stream, additionally performing the provided action on each element.
peek(Consumer<? super R>) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Returns a stream containing all the elements from this stream, additionally performing the provided action on each element.
peek(Consumer<? super T>) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Returns a stream containing all the elements from this stream, additionally performing the provided action on each element.
PeekingOperators<T> - Interface in org.eclipse.microprofile.reactive.streams: Operations for peeking at elements and signals in the stream, without impacting the stream itself.
ProcessorBuilder<T,R> - Interface in org.eclipse.microprofile.reactive.streams: A builder for a Processor.
ProducesResult<T> - Interface in org.eclipse.microprofile.reactive.streams: A stream that completes with a single result.
PublisherBuilder<T> - Interface in org.eclipse.microprofile.reactive.streams: A builder for a Publisher.

R

ReactiveStreams - Class in org.eclipse.microprofile.reactive.streams: Primary entry point into the Reactive Streams utility API.
ReactiveStreamsFactory - Interface in org.eclipse.microprofile.reactive.streams: Factory interface for providing the implementation of the static factory methods in ReactiveStreams.
ReactiveStreamsFactoryResolver - Class in org.eclipse.microprofile.reactive.streams: This class is not intended to be used by end-users but for portable container integration purpose only.
ReactiveStreamsFactoryResolver() - Constructor for class org.eclipse.microprofile.reactive.streams.ReactiveStreamsFactoryResolver
reduce(T, BinaryOperator<T>) - Method in interface org.eclipse.microprofile.reactive.streams.ConsumingOperators: Perform a reduction on the elements of this stream, using the provided identity value and the accumulation function.
reduce(BinaryOperator<T>) - Method in interface org.eclipse.microprofile.reactive.streams.ConsumingOperators: Perform a reduction on the elements of this stream, using provided the accumulation function.
reduce(R, BinaryOperator<R>) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Perform a reduction on the elements of this stream, using the provided identity value and the accumulation function.
reduce(BinaryOperator<R>) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Perform a reduction on the elements of this stream, using provided the accumulation function.
reduce(T, BinaryOperator<T>) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Perform a reduction on the elements of this stream, using the provided identity value and the accumulation function.
reduce(BinaryOperator<T>) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Perform a reduction on the elements of this stream, using provided the accumulation function.
run() - Method in interface org.eclipse.microprofile.reactive.streams.CompletionRunner: Run this stream, using the first ReactiveStreamsEngine found by the ServiceLoader.
run(ReactiveStreamsEngine) - Method in interface org.eclipse.microprofile.reactive.streams.CompletionRunner: Run this stream, using the supplied ReactiveStreamsEngine.

S

setInstance(ReactiveStreamsFactory) - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreamsFactoryResolver: Set the instance.
skip(long) - Method in interface org.eclipse.microprofile.reactive.streams.FilteringOperators: Discard the first n of this stream.
skip(long) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Discard the first n of this stream.
skip(long) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Discard the first n of this stream.
SubscriberBuilder<T,R> - Interface in org.eclipse.microprofile.reactive.streams: A builder for a Subscriber and its result.

T

takeWhile(Predicate<? super T>) - Method in interface org.eclipse.microprofile.reactive.streams.FilteringOperators: Take the longest prefix of elements from this stream that satisfy the given predicate.
takeWhile(Predicate<? super R>) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Take the longest prefix of elements from this stream that satisfy the given predicate.
takeWhile(Predicate<? super T>) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Take the longest prefix of elements from this stream that satisfy the given predicate.
to(Subscriber<? super T>) - Method in interface org.eclipse.microprofile.reactive.streams.ConnectingOperators: Connect the outlet of the Publisher built by this builder to the given Subscriber.
to(SubscriberBuilder<? super T, ? extends R>) - Method in interface org.eclipse.microprofile.reactive.streams.ConnectingOperators: Connect the outlet of this stream to the given SubscriberBuilder graph.
to(Subscriber<? super R>) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Connect the outlet of the Publisher built by this builder to the given Subscriber.
to(SubscriberBuilder<? super R, ? extends S>) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Connect the outlet of this stream to the given SubscriberBuilder graph.
to(Subscriber<? super T>) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Connect the outlet of the Publisher built by this builder to the given Subscriber.
to(SubscriberBuilder<? super T, ? extends R>) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Connect the outlet of this stream to the given SubscriberBuilder graph.
toList() - Method in interface org.eclipse.microprofile.reactive.streams.ConsumingOperators: Collect the elements emitted by this stream into a List.
toList() - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Collect the elements emitted by this stream into a List.
toList() - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Collect the elements emitted by this stream into a List.
TransformingOperators<T> - Interface in org.eclipse.microprofile.reactive.streams: Operations for transforming a stream.

V

via(ProcessorBuilder<? super T, ? extends R>) - Method in interface org.eclipse.microprofile.reactive.streams.ConnectingOperators: Connect the outlet of the Publisher built by this builder to the given ProcessorBuilder.
via(Processor<? super T, ? extends R>) - Method in interface org.eclipse.microprofile.reactive.streams.ConnectingOperators: Connect the outlet of this stream to the given Processor graph.
via(ProcessorBuilder<? super R, ? extends S>) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Connect the outlet of the Publisher built by this builder to the given ProcessorBuilder.
via(Processor<? super R, ? extends S>) - Method in interface org.eclipse.microprofile.reactive.streams.ProcessorBuilder: Connect the outlet of this stream to the given Processor graph.
via(ProcessorBuilder<? super T, ? extends R>) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Connect the outlet of the Publisher built by this builder to the given ProcessorBuilder.
via(Processor<? super T, ? extends R>) - Method in interface org.eclipse.microprofile.reactive.streams.PublisherBuilder: Connect the outlet of this stream to the given Processor graph.

B C D E F G I L M O P R S T V