- of(Subscriber<T>, CompletionStage<R>) - Static method in interface org.eclipse.microprofile.reactive.streams.CompletionSubscriber
-
- of(T) - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreams
-
- of(T...) - Static method in class org.eclipse.microprofile.reactive.streams.ReactiveStreams
-
- of(T) - Method in interface org.eclipse.microprofile.reactive.streams.ReactiveStreamsFactory
-
- of(T...) - Method in interface org.eclipse.microprofile.reactive.streams.ReactiveStreamsFactory
-
- 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.
- org.eclipse.microprofile.reactive.streams.spi - package org.eclipse.microprofile.reactive.streams.spi
-
The Reactive Streams utils SPI.
- 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.
- 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.spi
-
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.spi.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 the provided 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 the provided 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 the provided 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
.
- setInstance(ReactiveStreamsFactory) - Static method in class org.eclipse.microprofile.reactive.streams.spi.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.
- Stage - Interface in org.eclipse.microprofile.reactive.streams.spi
-
A stage of a Reactive Streams graph.
- Stage.Cancel - Interface in org.eclipse.microprofile.reactive.streams.spi
-
A cancelling stage.
- Stage.Collect - Interface in org.eclipse.microprofile.reactive.streams.spi
-
A collect stage.
- Stage.Concat - Interface in org.eclipse.microprofile.reactive.streams.spi
-
Concatenate the given graphs together.
- Stage.Coupled - Interface in org.eclipse.microprofile.reactive.streams.spi
-
A stage that couples a wrapped subscriber graph to a wrapped publisher graph.
- Stage.Distinct - Interface 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 - Interface in org.eclipse.microprofile.reactive.streams.spi
-
A drop while stage.
- Stage.Failed - Interface in org.eclipse.microprofile.reactive.streams.spi
-
A failed publisher.
- Stage.Filter - Interface in org.eclipse.microprofile.reactive.streams.spi
-
A filter stage.
- Stage.FindFirst - Interface in org.eclipse.microprofile.reactive.streams.spi
-
A subscriber stage that emits the first element encountered.
- Stage.FlatMap - Interface in org.eclipse.microprofile.reactive.streams.spi
-
A flat map stage.
- Stage.FlatMapCompletionStage - Interface in org.eclipse.microprofile.reactive.streams.spi
-
- Stage.FlatMapIterable - Interface in org.eclipse.microprofile.reactive.streams.spi
-
A flat map stage that emits and fattens
Iterable
.
- Stage.FromCompletionStage - Interface in org.eclipse.microprofile.reactive.streams.spi
-
- Stage.FromCompletionStageNullable - Interface in org.eclipse.microprofile.reactive.streams.spi
-
- Stage.Limit - Interface in org.eclipse.microprofile.reactive.streams.spi
-
A limit stage.
- Stage.Map - Interface in org.eclipse.microprofile.reactive.streams.spi
-
A map stage.
- Stage.Of - Interface in org.eclipse.microprofile.reactive.streams.spi
-
A publisher of zero to many values.
- Stage.OnComplete - Interface 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 - Interface 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 - Interface in org.eclipse.microprofile.reactive.streams.spi
-
A stage to handle errors from upstream.
- Stage.OnErrorResumeWith - Interface in org.eclipse.microprofile.reactive.streams.spi
-
A stage to handle errors from upstream.
- Stage.OnTerminate - Interface 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, completes, or is cancelled by downstream.
- Stage.Peek - Interface in org.eclipse.microprofile.reactive.streams.spi
-
A stage returning a stream containing all the elements from this stream,
additionally performing the provided action on each element.
- Stage.ProcessorStage - Interface in org.eclipse.microprofile.reactive.streams.spi
-
A processor stage.
- Stage.PublisherStage - Interface in org.eclipse.microprofile.reactive.streams.spi
-
A publisher stage.
- Stage.Skip - Interface in org.eclipse.microprofile.reactive.streams.spi
-
A skip stage.
- Stage.SubscriberStage - Interface in org.eclipse.microprofile.reactive.streams.spi
-
A subscriber.
- Stage.TakeWhile - Interface in org.eclipse.microprofile.reactive.streams.spi
-
A take while stage.
- SubscriberBuilder<T,R> - Interface in org.eclipse.microprofile.reactive.streams
-
A builder for a Subscriber
and its result.
- SubscriberWithCompletionStage<T,R> - Interface in org.eclipse.microprofile.reactive.streams.spi
-
A subscriber and completion stage pair.