A B C D E F G H I J K L M N O P Q R S T U V W X Z

R

race(T, Function<? super T, ? extends T>, Predicate<? super T>, BiPredicate<? super T, ? super T>) - Static method in class reactor.test.util.RaceTestUtils

Synchronizes the execution of two concurrent state modifications as much as possible to test race conditions.

race(Runnable...) - Static method in class reactor.test.util.RaceTestUtils

Synchronizes the execution of several Runnables as much as possible to test race conditions.

race(Runnable, Runnable) - Static method in class reactor.test.util.RaceTestUtils

Synchronizes the execution of two Runnables as much as possible to test race conditions.

race(Runnable, Runnable, Scheduler) - Static method in class reactor.test.util.RaceTestUtils

Deprecated.

Use RaceTestUtils.race(Scheduler, Runnable...). To be removed in 3.6.0, at the earliest.

race(Scheduler, Runnable...) - Static method in class reactor.test.util.RaceTestUtils

Synchronizes the execution of several Runnables as much as possible to test race conditions.

race(int, Scheduler, Runnable...) - Static method in class reactor.test.util.RaceTestUtils

Synchronizes the execution of several Runnables as much as possible to test race conditions.

RaceTestUtils - Class in reactor.test.util

RaceTestUtils() - Constructor for class reactor.test.util.RaceTestUtils

range(int, int) - Static method in class reactor.core.publisher.Flux

Build a Flux that will only emit a sequence of count incrementing integers, starting from start.

reactor.adapter - package reactor.adapter

Adapt Publisher to Java 9+ Flow.Publisher.

reactor.core - package reactor.core

Core components of the framework supporting extensions to the Reactive Stream programming model.

reactor.core.observability - package reactor.core.observability

reactor.core.observability.micrometer - package reactor.core.observability.micrometer

Support of Micrometer 1.10+ instrumentation on reactor-core classes.

reactor.core.publisher - package reactor.core.publisher

Provide main Reactive APIs in Flux and Mono, as well as various helper classes, interfaces used in the composition API, variants of Flux and operator-building utilities.

reactor.core.scheduler - package reactor.core.scheduler

Scheduler contract and static registry and factory methods in Schedulers.

reactor.test - package reactor.test

Main test components supporting the testing and assertion of publishers.

reactor.test.publisher - package reactor.test.publisher

Components supporting the creation of test-oriented Publishers.

reactor.test.scheduler - package reactor.test.scheduler

Components supporting the creation of test-oriented Schedulers.

reactor.test.subscriber - package reactor.test.subscriber

Components supporting the creation of test-oriented Subscribers.

reactor.test.util - package reactor.test.util

reactor.tools.agent - package reactor.tools.agent

reactor.util - package reactor.util

Miscellaneous utility classes, such as loggers, tuples or queue suppliers and implementations.

reactor.util.annotation - package reactor.util.annotation

reactor.util.concurrent - package reactor.util.concurrent

Queue suppliers and utilities Used for operational serialization (serializing threads) or buffering (asynchronous boundary).

reactor.util.context - package reactor.util.context

Miscellaneous utility classes, such as loggers, tuples or queue suppliers and implementations.

reactor.util.function - package reactor.util.function

Tuples provide a type-safe way to specify multiple parameters.

reactor.util.retry - package reactor.util.retry

ReactorBlockHoundIntegration - Class in reactor.core.scheduler

BlockHoundIntegration with Reactor's scheduling mechanism.

ReactorBlockHoundIntegration() - Constructor for class reactor.core.scheduler.ReactorBlockHoundIntegration

ReactorContextAccessor - Class in reactor.util.context

A ContextAccessor to enable reading values from a Reactor ContextView and writing values to Context.

ReactorContextAccessor() - Constructor for class reactor.util.context.ReactorContextAccessor

ReactorDebugAgent - Class in reactor.tools.agent

ReactorDebugAgent() - Constructor for class reactor.tools.agent.ReactorDebugAgent

ReactorDebugByteBuddyPlugin - Class in reactor.tools.agent

ReactorDebugByteBuddyPlugin() - Constructor for class reactor.tools.agent.ReactorDebugByteBuddyPlugin

readableType() - Method in class reactor.util.context.ReactorContextAccessor

readOnly() - Method in interface reactor.util.context.Context

Switch to the ContextView interface, which only allows reading from the context.

readValue(ContextView, Object) - Method in class reactor.util.context.ReactorContextAccessor

readValues(ContextView, Predicate<Object>, Map<Object, Object>) - Method in class reactor.util.context.ReactorContextAccessor

recordWith(Supplier<? extends Collection<T>>) - Method in interface reactor.test.StepVerifier.Step

Start a recording session storing Subscriber.onNext(Object) values in the supplied Collection.

reduce(BiFunction<T, T, T>) - Method in class reactor.core.publisher.Flux

Reduce the values from this Flux sequence into a single object of the same type than the emitted items.

reduce(A, BiFunction<A, ? super T, A>) - Method in class reactor.core.publisher.Flux

Reduce the values from this Flux sequence into a single object matching the type of a seed value.

reduce(BiFunction<T, T, T>) - Method in class reactor.core.publisher.ParallelFlux

Reduces all values within a 'rail' and across 'rails' with a reducer function into a single sequential value.

reduce(Supplier<R>, BiFunction<R, ? super T, R>) - Method in class reactor.core.publisher.ParallelFlux

Reduces all values within a 'rail' to a single value (with a possibly different type) via a reducer function that is initialized on each rail from an initialSupplier value.

reduceWith(Supplier<A>, BiFunction<A, ? super T, A>) - Method in class reactor.core.publisher.Flux

Reduce the values from this Flux sequence into a single object matching the type of a lazily supplied seed value.

refCount() - Method in class reactor.core.publisher.ConnectableFlux

Connects to the upstream source when the first Subscriber subscribes and disconnects when all Subscribers cancelled or the upstream source completed.

refCount(int) - Method in class reactor.core.publisher.ConnectableFlux

Connects to the upstream source when the given number of Subscriber subscribes and disconnects when all Subscribers cancelled or the upstream source completed.

refCount(int, Duration) - Method in class reactor.core.publisher.ConnectableFlux

Connects to the upstream source when the given number of Subscriber subscribes.

refCount(int, Duration, Scheduler) - Method in class reactor.core.publisher.ConnectableFlux

Connects to the upstream source when the given number of Subscriber subscribes.

remove(Disposable) - Method in interface reactor.core.Disposable.Composite

Delete the Disposable from this container, without disposing it.

remove() - Method in interface reactor.core.Fuseable.QueueSubscription

remove(Object) - Method in interface reactor.core.Fuseable.QueueSubscription

remove(SinkManyBestEffort.DirectInner<T>) - Method in class reactor.core.publisher.DirectProcessor

Deprecated.

removeAll(Collection<?>) - Method in interface reactor.core.Fuseable.QueueSubscription

removeExecutorServiceDecorator(String) - Static method in class reactor.core.scheduler.Schedulers

Remove an existing ScheduledExecutorService decorator if it has been set up via Schedulers.addExecutorServiceDecorator(String, BiFunction).

removeQueueWrapper(String) - Static method in class reactor.core.publisher.Hooks

Removes existing Queue wrapper by key.

removeQueueWrappers() - Static method in class reactor.core.publisher.Hooks

Remove all queue wrappers.

repeat() - Method in class reactor.core.publisher.Flux

Repeatedly and indefinitely subscribe to the source upon completion of the previous subscription.

repeat(BooleanSupplier) - Method in class reactor.core.publisher.Flux

Repeatedly subscribe to the source if the predicate returns true after completion of the previous subscription.

repeat(long) - Method in class reactor.core.publisher.Flux

Repeatedly subscribe to the source numRepeat times.

repeat(long, BooleanSupplier) - Method in class reactor.core.publisher.Flux

Repeatedly subscribe to the source if the predicate returns true after completion of the previous subscription.

repeat() - Method in class reactor.core.publisher.Mono

Repeatedly and indefinitely subscribe to the source upon completion of the previous subscription.

repeat(BooleanSupplier) - Method in class reactor.core.publisher.Mono

Repeatedly subscribe to the source if the predicate returns true after completion of the previous subscription.

repeat(long) - Method in class reactor.core.publisher.Mono

Repeatedly subscribe to the source numRepeat times.

repeat(long, BooleanSupplier) - Method in class reactor.core.publisher.Mono

Repeatedly subscribe to the source if the predicate returns true after completion of the previous subscription.

repeatWhen(Function<Flux<Long>, ? extends Publisher<?>>) - Method in class reactor.core.publisher.Flux

Repeatedly subscribe to this Flux when a companion sequence emits elements in response to the flux completion signal.

repeatWhen(Function<Flux<Long>, ? extends Publisher<?>>) - Method in class reactor.core.publisher.Mono

Repeatedly subscribe to this Mono when a companion sequence emits elements in response to the flux completion signal.

repeatWhenEmpty(Function<Flux<Long>, ? extends Publisher<?>>) - Method in class reactor.core.publisher.Mono

Repeatedly subscribe to this Mono as long as the current subscription to this Mono completes empty and the companion Publisher produces an onNext signal.

repeatWhenEmpty(int, Function<Flux<Long>, ? extends Publisher<?>>) - Method in class reactor.core.publisher.Mono

Repeatedly subscribe to this Mono as long as the current subscription to this Mono completes empty and the companion Publisher produces an onNext signal.

replace(Disposable) - Method in interface reactor.core.Disposable.Swap

Atomically set the next Disposable on this container but don't dispose the previous one (if any).

replace(AtomicReferenceFieldUpdater<F, Subscription>, F, Subscription) - Static method in class reactor.core.publisher.Operators

A generic utility to atomically replace a subscription or cancel the replacement if the current subscription is marked as already cancelled (as in Operators.cancelledSubscription()).

replay() - Method in class reactor.core.publisher.Flux

Turn this Flux into a hot source and cache last emitted signals for further Subscriber.

replay(int) - Method in class reactor.core.publisher.Flux

Turn this Flux into a connectable hot source and cache last emitted signals for further Subscriber.

replay(Duration) - Method in class reactor.core.publisher.Flux

Turn this Flux into a connectable hot source and cache last emitted signals for further Subscriber.

replay(int, Duration) - Method in class reactor.core.publisher.Flux

Turn this Flux into a connectable hot source and cache last emitted signals for further Subscriber.

replay(Duration, Scheduler) - Method in class reactor.core.publisher.Flux

Turn this Flux into a connectable hot source and cache last emitted signals for further Subscriber.

replay(int, Duration, Scheduler) - Method in class reactor.core.publisher.Flux

Turn this Flux into a connectable hot source and cache last emitted signals for further Subscriber.

replay() - Method in interface reactor.core.publisher.Sinks.ManySpec

Help building Sinks.Many that will broadcast signals to multiple Subscriber with the ability to retain and replay all or an arbitrary number of elements.

ReplayProcessor<T> - Class in reactor.core.publisher

Deprecated.

To be removed in 3.5, prefer clear cut usage of Sinks through variations under Sinks.many().replay().

reportBadRequest(long) - Static method in class reactor.core.publisher.Operators

Log an IllegalArgumentException if the request is null or negative.

reportMoreProduced() - Static method in class reactor.core.publisher.Operators

Log an IllegalStateException that indicates more than the requested amount was produced.

reportSubscriptionSet() - Static method in class reactor.core.publisher.Operators

Log a duplicate subscription error.

reportThrowInSubscribe(CoreSubscriber<?>, Throwable) - Static method in class reactor.core.publisher.Operators

Report a Throwable that was thrown from a call to Publisher.subscribe(Subscriber), attempting to notify the Subscriber by: providing a special Subscription via Subscriber.onSubscribe(Subscription) immediately delivering an onError signal after that

request(long) - Method in class reactor.core.publisher.BaseSubscriber

request(long) - Method in class reactor.core.publisher.MonoProcessor

Deprecated.

the MonoProcessor will cease to implement Subscription in 3.5

request(long) - Method in class reactor.core.publisher.Operators.DeferredSubscription

request(long) - Method in class reactor.core.publisher.Operators.MonoSubscriber

request(long) - Method in class reactor.core.publisher.UnicastProcessor

Deprecated.

request(long) - Method in interface reactor.test.subscriber.TestSubscriber

Request n elements from the Publisher's Subscription.

REQUESTED_FROM_DOWNSTREAM - Static variable in class reactor.core.Scannable.Attr

A Long attribute exposing the current pending demand of a downstream component.

requestedFromDownstream() - Method in interface reactor.core.publisher.FluxSink

The current outstanding request amount.

requestFusion(int) - Method in interface reactor.core.Fuseable.QueueSubscription

Request a specific fusion mode from this QueueSubscription.

requestFusion(int) - Method in interface reactor.core.Fuseable.SynchronousSubscription

requestFusion(int) - Method in class reactor.core.publisher.Operators.MonoSubscriber

requestFusion(int) - Method in class reactor.core.publisher.UnicastProcessor

Deprecated.

requestUnbounded() - Method in class reactor.core.publisher.BaseSubscriber

Request an unbounded amount.

requireFusion(int) - Method in class reactor.test.subscriber.TestSubscriberBuilder

Expect fusion to be possible with the TestSubscriber, with Fuseable.NONE) being a special case.

requireFusion(int, int) - Method in class reactor.test.subscriber.TestSubscriberBuilder

Expect fusion to be possible with the TestSubscriber, with both parameters set to Fuseable.NONE being a special case.

requireNotFuseable() - Method in class reactor.test.subscriber.TestSubscriberBuilder

Enforce that the Subscription passed to the TestSubscriber isn't a Fuseable.QueueSubscription.

reset() - Static method in class reactor.test.scheduler.VirtualTimeScheduler

Re-activate the global Schedulers and potentially customized Schedulers.Factory that were active prior to last activation of VirtualTimeScheduler factories.

reset() - Method in class reactor.test.util.TestLogger

resetDefaultTimeout() - Static method in interface reactor.test.StepVerifier

Reset the StepVerifier.verify() timeout to the "unlimited" default.

resetFactory() - Static method in class reactor.core.scheduler.Schedulers

Re-apply default factory to Schedulers

resetFrom(Schedulers.Snapshot) - Static method in class reactor.core.scheduler.Schedulers

Replace the current Factory and shared Schedulers with the ones saved in a previously captured snapshot.

resetLoggerFactory() - Static method in class reactor.util.Loggers

Attempt to activate the best reactor Logger factory, by first attempting to use the SLF4J one, then falling back to either Console logging or java.util.logging.Logger).

resetOnEachOperator(String) - Static method in class reactor.core.publisher.Hooks

Remove the sub-hook with key key from the onEachOperator hook.

resetOnEachOperator() - Static method in class reactor.core.publisher.Hooks

Reset global "assembly" hook tracking

resetOnErrorDropped() - Static method in class reactor.core.publisher.Hooks

Reset global error dropped strategy to bubbling back the error.

resetOnHandleError() - Static method in class reactor.core.scheduler.Schedulers

Reset the Schedulers.onHandleError(BiConsumer) hook to the default no-op behavior, erasing all sub-hooks that might have individually added via Schedulers.onHandleError(String, BiConsumer) or the whole hook set via Schedulers.onHandleError(BiConsumer).

resetOnHandleError(String) - Static method in class reactor.core.scheduler.Schedulers

Reset a specific onHandleError hook part keyed to the provided String, removing that sub-hook if it has previously been defined via Schedulers.onHandleError(String, BiConsumer).

resetOnLastOperator(String) - Static method in class reactor.core.publisher.Hooks

Remove the sub-hook with key key from the onLastOperator hook.

resetOnLastOperator() - Static method in class reactor.core.publisher.Hooks

Reset global "subscriber" hook tracking

resetOnNextDropped() - Static method in class reactor.core.publisher.Hooks

Reset global data dropped strategy to throwing via Exceptions.failWithCancel()

resetOnNextError() - Static method in class reactor.core.publisher.Hooks

Reset global onNext error handling strategy to terminating the sequence with an onError and cancelling upstream (OnNextFailureStrategy.STOP).

resetOnOperatorDebug() - Static method in class reactor.core.publisher.Hooks

Reset global operator debug.

resetOnOperatorError(String) - Static method in class reactor.core.publisher.Hooks

Remove the sub-hook with key key from the onOperatorError hook.

resetOnOperatorError() - Static method in class reactor.core.publisher.Hooks

Reset global operator error mapping to the default behavior.

resetOnScheduleHook(String) - Static method in class reactor.core.scheduler.Schedulers

Reset a specific onScheduleHook sub-hook if it has been set up via Schedulers.onScheduleHook(String, Function).

resetOnScheduleHooks() - Static method in class reactor.core.scheduler.Schedulers

Remove all onScheduleHook sub-hooks.

retainAll(Collection<?>) - Method in interface reactor.core.Fuseable.QueueSubscription

retry() - Method in class reactor.core.publisher.Flux

Re-subscribes to this Flux sequence if it signals any error, indefinitely.

retry(long) - Method in class reactor.core.publisher.Flux

Re-subscribes to this Flux sequence if it signals any error, for a fixed number of times.

retry() - Method in class reactor.core.publisher.Mono

Re-subscribes to this Mono sequence if it signals any error, indefinitely.

retry(long) - Method in class reactor.core.publisher.Mono

Re-subscribes to this Mono sequence if it signals any error, for a fixed number of times.

Retry - Class in reactor.util.retry

Base abstract class for a strategy to decide when to retry given a companion Flux of Retry.RetrySignal, for use with Flux.retryWhen(Retry) and Mono.retryWhen(Retry).

Retry() - Constructor for class reactor.util.retry.Retry

Retry(ContextView) - Constructor for class reactor.util.retry.Retry

Retry.RetrySignal - Interface in reactor.util.retry

State used in Flux.retryWhen(Retry) and Mono.retryWhen(Retry), providing the Throwable that caused the source to fail as well as counters keeping track of retries.

RetryBackoffSpec - Class in reactor.util.retry

A Retry strategy based on exponential backoffs, with configurable features.

retryContext - Variable in class reactor.util.retry.Retry

retryContext() - Method in class reactor.util.retry.Retry

Return the user provided context that was set at construction time.

retryContextView() - Method in interface reactor.util.retry.Retry.RetrySignal

Return a read-only view of the user provided context, which may be used to store objects to be reset/rolled-back or otherwise mutated before or after a retry.

retryExhausted(String, Throwable) - Static method in class reactor.core.Exceptions

Return a new RuntimeException that represents too many failures on retry.

RetrySpec - Class in reactor.util.retry

A simple count-based Retry strategy with configurable features.

retryWhen(Retry) - Method in class reactor.core.publisher.Flux

Retries this Flux in response to signals emitted by a companion Publisher.

retryWhen(Retry) - Method in class reactor.core.publisher.Mono

Retries this Mono in response to signals emitted by a companion Publisher.

RUN_ON - Static variable in class reactor.core.Scannable.Attr

A key that links a Scannable to another Scannable it runs on.

RUN_STYLE - Static variable in class reactor.core.Scannable.Attr

An Scannable.Attr.RunStyle enum attribute indicating whether or not an operator continues to operate on the same thread.

runOn(Scheduler) - Method in class reactor.core.publisher.ParallelFlux

Specifies where each 'rail' will observe its incoming values with possible work-stealing and default prefetch amount.

runOn(Scheduler, int) - Method in class reactor.core.publisher.ParallelFlux

Specifies where each 'rail' will observe its incoming values with possible work-stealing and a given prefetch amount.

A B C D E F G H I J K L M N O P Q R S T U V W X Z