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

B

build() - Method in class org.eclipse.microprofile.reactive.streams.SubscriberBuilder

Build this stream, using the first ReactiveStreamsEngine found by the ServiceLoader.

build(ReactiveStreamsEngine) - Method in class org.eclipse.microprofile.reactive.streams.SubscriberBuilder

Build this stream, using the supplied ReactiveStreamsEngine.

buildCompletion(Graph) - Method in interface org.eclipse.microprofile.reactive.streams.spi.ReactiveStreamsEngine

Build a closed graph from the given stages.

builder() - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreams

Create a ProcessorBuilder.

buildGraphFor(PublisherBuilder<?>) - Static method in class org.eclipse.microprofile.reactive.streams.GraphAccessor

Build the graph for the given PublisherBuilder.

buildGraphFor(ProcessorBuilder<?, ?>) - Static method in class org.eclipse.microprofile.reactive.streams.GraphAccessor

Build the graph for the given ProcessorBuilder.

buildGraphFor(SubscriberBuilder<?, ?>) - Static method in class org.eclipse.microprofile.reactive.streams.GraphAccessor

Build the graph for the given SubscriberBuilder.

buildGraphFor(CompletionRunner<?>) - Static method in class org.eclipse.microprofile.reactive.streams.GraphAccessor

Build the graph for the given CompletionRunner.

buildProcessor(Graph) - Method in interface org.eclipse.microprofile.reactive.streams.spi.ReactiveStreamsEngine

Build a Processor from the given stages.

buildPublisher(Graph) - Method in interface org.eclipse.microprofile.reactive.streams.spi.ReactiveStreamsEngine

Build a Publisher from the given stages.

buildRs() - Method in class org.eclipse.microprofile.reactive.streams.ProcessorBuilder

Build this stream, using the first ReactiveStreamsEngine found by the ServiceLoader.

buildRs(ReactiveStreamsEngine) - Method in class org.eclipse.microprofile.reactive.streams.ProcessorBuilder

Build this stream, using the supplied ReactiveStreamsEngine.

buildRs() - Method in class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Build this stream, using the first ReactiveStreamsEngine found by the ServiceLoader.

buildRs(ReactiveStreamsEngine) - Method in class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Build this stream, using the supplied ReactiveStreamsEngine.

buildSubscriber(Graph) - Method in interface org.eclipse.microprofile.reactive.streams.spi.ReactiveStreamsEngine

Build a Subscriber from the given stages.

C

cancel() - Method in class org.eclipse.microprofile.reactive.streams.ProcessorBuilder

Cancels the stream as soon as it starts.

cancel() - Method in class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Cancels the stream as soon as it starts.

collect(Collector<? super R, A, S>) - Method in class org.eclipse.microprofile.reactive.streams.ProcessorBuilder

Collect the elements emitted by this processor builder using the given Collector.

collect(Supplier<S>, BiConsumer<S, ? super R>) - Method in class org.eclipse.microprofile.reactive.streams.ProcessorBuilder

Collect the elements emitted by this processor builder using a Collector built from the given supplier and accumulator.

collect(Collector<? super T, A, R>) - Method in class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Collect the elements emitted by this publisher builder using the given Collector.

collect(Supplier<R>, BiConsumer<R, ? super T>) - Method in class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Collect the elements emitted by this processor builder using a Collector built from the given supplier and accumulator.

Collect(Collector<?, ?, ?>) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Stage.Collect

CompletionRunner<T> - Class in org.eclipse.microprofile.reactive.streams

A builder for a closed reactive streams graph.

CompletionSubscriber<T,R> - Class 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(Graph, Graph) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Stage.Concat

D

distinct() - Method in class 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 class 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 R>) - Method in class 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 class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Drop the longest prefix of elements from this stream that satisfy the given predicate.

DropWhile(Predicate<?>) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Stage.DropWhile

E

empty() - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreams

Create an empty PublisherBuilder.

EMPTY - Static variable in class org.eclipse.microprofile.reactive.streams.spi.Stage.Of

Instance used for an empty stream.

equals(Object) - Method in class org.eclipse.microprofile.reactive.streams.CompletionSubscriber

F

failed(Throwable) - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreams

Create a failed PublisherBuilder.

Failed(Throwable) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Stage.Failed

filter(Predicate<? super R>) - Method in class org.eclipse.microprofile.reactive.streams.ProcessorBuilder

Filter elements emitted by this processor using the given Predicate.

filter(Predicate<? super T>) - Method in class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Filter elements emitted by this publisher using the given Predicate.

Filter(Predicate<?>) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Stage.Filter

findFirst() - Method in class org.eclipse.microprofile.reactive.streams.ProcessorBuilder

Find the first element emitted by the Processor, and return it in a CompletionStage.

findFirst() - Method in class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Find the first element emitted by the Publisher, and return it in a CompletionStage.

flatMap(Function<? super R, PublisherBuilder<? extends S>>) - Method in class 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, PublisherBuilder<? extends S>>) - Method in class 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<?, Graph>) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Stage.FlatMap

flatMapCompletionStage(Function<? super R, ? extends CompletionStage<? extends S>>) - Method in class 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 processor.

flatMapCompletionStage(Function<? super T, ? extends CompletionStage<? extends S>>) - Method in class 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 publisher.

FlatMapCompletionStage(Function<?, CompletionStage<?>>) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Stage.FlatMapCompletionStage

flatMapIterable(Function<? super R, ? extends Iterable<? extends S>>) - Method in class 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 class 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<?, Iterable<?>>) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Stage.FlatMapIterable

flatMapPublisher(Function<? super R, Publisher<? extends S>>) - Method in class 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.

flatMapPublisher(Function<? super T, Publisher<? extends S>>) - Method in class 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.

forEach(Consumer<? super R>) - Method in class org.eclipse.microprofile.reactive.streams.ProcessorBuilder

Performs an action for each element on this stream.

forEach(Consumer<? super T>) - Method in class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Performs an action for each element on this stream.

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.

fromProcessor(Processor<? super T, ? extends R>) - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreams

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.

fromSubscriber(Subscriber<? extends T>) - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreams

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.

getAction() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.OnComplete

The action to execute.

getAction() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.OnTerminate

The action to execute.

getCollector() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.Collect

The collector.

getCompletion() - Method in class org.eclipse.microprofile.reactive.streams.CompletionSubscriber

Get the completion stage.

getConsumer() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.OnError

The error handler.

getConsumer() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.Peek

The consumer function.

getElements() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.Of

The elements to emit.

getError() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.Failed

getFirst() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.Concat

getFunction() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.OnErrorResume

The error handler.

getFunction() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.OnErrorResumeWith

The error handler.

getLimit() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.Limit

The limit.

getMapper() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.FlatMap

The mapper function.

getMapper() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.FlatMapCompletionStage

The mapper function.

getMapper() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.FlatMapIterable

The mapper function.

getMapper() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.Map

The mapper function.

getPredicate() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.DropWhile

The predicate.

getPredicate() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.Filter

The predicate.

getPredicate() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.TakeWhile

The predicate.

getRsProcessor() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.ProcessorStage

The processor.

getRsPublisher() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.PublisherStage

The publisher.

getRsSubscriber() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.SubscriberStage

The subscriber.

getSecond() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.Concat

getSkip() - Method in class org.eclipse.microprofile.reactive.streams.spi.Stage.Skip

The number of elements to skip.

getStages() - Method in class org.eclipse.microprofile.reactive.streams.spi.Graph

Get the stages of this graph.

Graph - Class in org.eclipse.microprofile.reactive.streams.spi

A graph.

Graph(Collection<Stage>) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Graph

Create a graph from the given stages.

GraphAccessor - Class in org.eclipse.microprofile.reactive.streams

Exists to allow access to the toGraph methods on each builder, so that these methods don't have to be exposed publicly in the API.

H

hashCode() - Method in class org.eclipse.microprofile.reactive.streams.CompletionSubscriber

hasInlet() - Method in class org.eclipse.microprofile.reactive.streams.spi.Graph

Returns true if this graph has an inlet, ie, if this graph can be turned into a Subscriber.

hasInlet() - Method in interface org.eclipse.microprofile.reactive.streams.spi.Stage

Whether this stage has an inlet - ie, when built, will it implement the Subscriber interface?

hasInlet() - Method in interface org.eclipse.microprofile.reactive.streams.spi.Stage.Inlet

hasOutlet() - Method in class org.eclipse.microprofile.reactive.streams.spi.Graph

Returns true if this graph has an outlet, ie, if this graph can be turned into a Publisher.

hasOutlet() - Method in interface org.eclipse.microprofile.reactive.streams.spi.Stage

Whether this stage has an outlet - ie, when built, will it implement the Publisher interface?

hasOutlet() - Method in interface org.eclipse.microprofile.reactive.streams.spi.Stage.Outlet

I

ignore() - Method in class org.eclipse.microprofile.reactive.streams.ProcessorBuilder

Ignores each element of this stream.

ignore() - Method in class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Ignores each element of this stream.

INSTANCE - Static variable in class org.eclipse.microprofile.reactive.streams.spi.Stage.Cancel

INSTANCE - Static variable in class org.eclipse.microprofile.reactive.streams.spi.Stage.Distinct

INSTANCE - Static variable in class org.eclipse.microprofile.reactive.streams.spi.Stage.FindFirst

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.

L

limit(long) - Method in class org.eclipse.microprofile.reactive.streams.ProcessorBuilder

Truncate this stream, ensuring the stream is no longer than maxSize elements in length.

limit(long) - Method in class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Truncate this stream, ensuring the stream is no longer than maxSize elements in length.

Limit(long) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Stage.Limit

M

map(Function<? super R, ? extends S>) - Method in class org.eclipse.microprofile.reactive.streams.ProcessorBuilder

Map the elements emitted by this processor using the mapper function.

map(Function<? super T, ? extends R>) - Method in class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Map the elements emitted by this publisher using the mapper function.

Map(Function<?, ?>) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Stage.Map

O

of(Subscriber<T>, CompletionStage<R>) - Static method in class 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(Iterable<?>) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Stage.Of

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.

onComplete() - Method in class org.eclipse.microprofile.reactive.streams.CompletionSubscriber

onComplete(Runnable) - Method in class 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 class 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.

OnComplete(Runnable) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Stage.OnComplete

onError(Throwable) - Method in class org.eclipse.microprofile.reactive.streams.CompletionSubscriber

onError(Consumer<Throwable>) - Method in class 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 class 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.

OnError(Consumer<Throwable>) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Stage.OnError

onErrorResume(Function<Throwable, R>) - Method in class org.eclipse.microprofile.reactive.streams.ProcessorBuilder

Returns a stream containing all the elements from this stream.

onErrorResume(Function<Throwable, T>) - Method in class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Returns a stream containing all the elements from this stream.

OnErrorResume(Function<Throwable, ?>) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Stage.OnErrorResume

onErrorResumeWith(Function<Throwable, PublisherBuilder<R>>) - Method in class org.eclipse.microprofile.reactive.streams.ProcessorBuilder

Returns a stream containing all the elements from this stream.

onErrorResumeWith(Function<Throwable, PublisherBuilder<T>>) - Method in class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Returns a stream containing all the elements from this stream.

OnErrorResumeWith(Function<Throwable, Graph>) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Stage.OnErrorResumeWith

onErrorResumeWithPublisher(Function<Throwable, Publisher<R>>) - Method in class org.eclipse.microprofile.reactive.streams.ProcessorBuilder

Returns a stream containing all the elements from this stream.

onErrorResumeWithPublisher(Function<Throwable, Publisher<? extends S>>) - Method in class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Returns a stream containing all the elements from this stream.

onNext(T) - Method in class org.eclipse.microprofile.reactive.streams.CompletionSubscriber

onSubscribe(Subscription) - Method in class org.eclipse.microprofile.reactive.streams.CompletionSubscriber

onTerminate(Runnable) - Method in class 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 class 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.

OnTerminate(Runnable) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Stage.OnTerminate

org.eclipse.microprofile.reactive.streams - package org.eclipse.microprofile.reactive.streams

MicroProfile Reactive Streams Operators.

org.eclipse.microprofile.reactive.streams.spi - package org.eclipse.microprofile.reactive.streams.spi

The Reactive Streams utils SPI.

P

peek(Consumer<? super R>) - Method in class 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 class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Returns a stream containing all the elements from this stream, additionally performing the provided action on each element.

Peek(Consumer<?>) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Stage.Peek

ProcessorBuilder<T,R> - Class in org.eclipse.microprofile.reactive.streams

A builder for a Processor.

ProcessorStage(Processor<?, ?>) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Stage.ProcessorStage

PublisherBuilder<T> - Class in org.eclipse.microprofile.reactive.streams

A builder for a Publisher.

PublisherStage(Publisher<?>) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Stage.PublisherStage

R

ReactiveStreams - Class in org.eclipse.microprofile.reactive.streams

Primary entry point into the Reactive Streams utility API.

ReactiveStreamsEngine - Interface in org.eclipse.microprofile.reactive.streams.spi

An engine for turning reactive streams graphs into Reactive Streams publishers/subscribers.

reduce(R, BinaryOperator<R>) - Method in class 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 class 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 class 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 class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Perform a reduction on the elements of this stream, using provided the accumulation function.

run() - Method in class org.eclipse.microprofile.reactive.streams.CompletionRunner

Run this stream, using the first ReactiveStreamsEngine found by the ServiceLoader.

run(ReactiveStreamsEngine) - Method in class org.eclipse.microprofile.reactive.streams.CompletionRunner

Run this stream, using the supplied ReactiveStreamsEngine.

S

skip(long) - Method in class org.eclipse.microprofile.reactive.streams.ProcessorBuilder

Discard the first n of this stream.

skip(long) - Method in class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Discard the first n of this stream.

Skip(long) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Stage.Skip

Stage - Interface in org.eclipse.microprofile.reactive.streams.spi

A stage of a Reactive Streams graph.

Stage.Cancel - Class in org.eclipse.microprofile.reactive.streams.spi

Stage.Collect - Class in org.eclipse.microprofile.reactive.streams.spi

A collect stage.

Stage.Concat - Class in org.eclipse.microprofile.reactive.streams.spi

Concatenate the given graphs together.

Stage.Distinct - Class in org.eclipse.microprofile.reactive.streams.spi

A stage returning a stream consisting of the distinct elements (according to Object.equals(Object)) of this stream.

Stage.DropWhile - Class in org.eclipse.microprofile.reactive.streams.spi

A drop while stage.

Stage.Failed - Class in org.eclipse.microprofile.reactive.streams.spi

A failed publisher.

Stage.Filter - Class in org.eclipse.microprofile.reactive.streams.spi

A filter stage.

Stage.FindFirst - Class in org.eclipse.microprofile.reactive.streams.spi

A subscriber stage that emits the first element encountered.

Stage.FlatMap - Class in org.eclipse.microprofile.reactive.streams.spi

A flat map stage.

Stage.FlatMapCompletionStage - Class in org.eclipse.microprofile.reactive.streams.spi

A flat map stage that emits and flattens CompletionStage.

Stage.FlatMapIterable - Class in org.eclipse.microprofile.reactive.streams.spi

A flat map stage that emits and fattens Iterable.

Stage.Inlet - Interface in org.eclipse.microprofile.reactive.streams.spi

Convenience interface for inlet stages.

Stage.Limit - Class in org.eclipse.microprofile.reactive.streams.spi

A limit stage.

Stage.Map - Class in org.eclipse.microprofile.reactive.streams.spi

A map stage.

Stage.Of - Class in org.eclipse.microprofile.reactive.streams.spi

A publisher of zero to many values.

Stage.OnComplete - Class in org.eclipse.microprofile.reactive.streams.spi

A stage returning a stream containing all the elements from this stream, additionally performing the provided action when this stream completes.

Stage.OnError - Class in org.eclipse.microprofile.reactive.streams.spi

A stage returning a stream containing all the elements from this stream, additionally performing the provided action if this stream conveys an error.

Stage.OnErrorResume - Class in org.eclipse.microprofile.reactive.streams.spi

A stage to handle error from upstream.

Stage.OnErrorResumeWith - Class in org.eclipse.microprofile.reactive.streams.spi

A stage to handle error from upstream.

Stage.OnTerminate - Class in org.eclipse.microprofile.reactive.streams.spi

A stage returning a stream containing all the elements from this stream, additionally performing the provided action if this stream terminates with an error or completes.

Stage.Outlet - Interface in org.eclipse.microprofile.reactive.streams.spi

Convenience interface for outlet stages.

Stage.Peek - Class in org.eclipse.microprofile.reactive.streams.spi

A stage returning a stream containing all the elements from this stream, additionaly perfoming the provided action on each element.

Stage.ProcessorStage - Class in org.eclipse.microprofile.reactive.streams.spi

A processor stage.

Stage.PublisherStage - Class in org.eclipse.microprofile.reactive.streams.spi

A publisher stage.

Stage.Skip - Class in org.eclipse.microprofile.reactive.streams.spi

A skip stage.

Stage.SubscriberStage - Class in org.eclipse.microprofile.reactive.streams.spi

A subscriber.

Stage.TakeWhile - Class in org.eclipse.microprofile.reactive.streams.spi

A take while stage.

SubscriberBuilder<T,R> - Class in org.eclipse.microprofile.reactive.streams

A builder for a Subscriber and its result.

SubscriberStage(Subscriber<?>) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Stage.SubscriberStage

T

takeWhile(Predicate<? super R>) - Method in class 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 class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Take the longest prefix of elements from this stream that satisfy the given predicate.

TakeWhile(Predicate<?>) - Constructor for class org.eclipse.microprofile.reactive.streams.spi.Stage.TakeWhile

to(Subscriber<R>) - Method in class org.eclipse.microprofile.reactive.streams.ProcessorBuilder

Connect the outlet of the Processor built by this builder to the given Subscriber.

to(SubscriberBuilder<R, S>) - Method in class org.eclipse.microprofile.reactive.streams.ProcessorBuilder

Connect the outlet of this processor builder to the given SubscriberBuilder graph.

to(Subscriber<T>) - Method in class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Connect the outlet of the Publisher built by this builder to the given Subscriber.

to(SubscriberBuilder<T, R>) - Method in class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Connect the outlet of this publisher builder to the given SubscriberBuilder graph.

toList() - Method in class org.eclipse.microprofile.reactive.streams.ProcessorBuilder

Collect the elements emitted by this processor builder into a List

toList() - Method in class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Collect the elements emitted by this publisher builder into a List

toString() - Method in class org.eclipse.microprofile.reactive.streams.CompletionSubscriber

toString() - Method in class org.eclipse.microprofile.reactive.streams.spi.Graph

U

UnsupportedStageException - Exception in org.eclipse.microprofile.reactive.streams.spi

Exception thrown when a reactive streams engine doesn't support a stage that is passed to it.

UnsupportedStageException(Stage) - Constructor for exception org.eclipse.microprofile.reactive.streams.spi.UnsupportedStageException

V

via(ProcessorBuilder<R, S>) - Method in class org.eclipse.microprofile.reactive.streams.ProcessorBuilder

Connect the outlet of the Processor built by this builder to the given Processor.

via(Processor<R, S>) - Method in class org.eclipse.microprofile.reactive.streams.ProcessorBuilder

Connect the outlet of this processor builder to the given ProcessorBuilder graph.

via(ProcessorBuilder<T, R>) - Method in class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Connect the outlet of the Publisher built by this builder to the given Processor.

via(Processor<T, R>) - Method in class org.eclipse.microprofile.reactive.streams.PublisherBuilder

Connect the outlet of this publisher builder to the given ProcessorBuilder graph.

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