Index (reactor-core 3.8.6-SNAPSHOT)

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
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

accept(Subscriber<? super T>) - Method in interface reactor.core.publisher.Signal: Propagate the signal represented by this Signal instance to a given Subscriber.
actual - Variable in class reactor.core.publisher.Operators.MonoSubscriber
actual() - Method in class reactor.core.publisher.Operators.MonoSubscriber
actual() - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
ACTUAL - Static variable in class reactor.core.Scannable.Attr: The direct dependent component downstream reference if any.
ACTUAL_METADATA - Static variable in class reactor.core.Scannable.Attr: Indicate that for some purposes a Scannable should be used as additional source of information about a contiguous Scannable in the chain.
actuals() - Method in interface reactor.core.Scannable: Return a Stream navigating the Subscriber chain (downward).
add(T) - Method in interface reactor.core.Fuseable.QueueSubscription
add(Disposable) - Method in interface reactor.core.Disposable.Composite: Add a Disposable to this container, if it is not disposed.
add(SinkManyBestEffort.DirectInner<T>) - Method in class reactor.core.publisher.DirectProcessor: Deprecated.
addAll(Collection<? extends Disposable>) - Method in interface reactor.core.Disposable.Composite: Adds the given collection of Disposables to the container or disposes them all if the container has been disposed.
addAll(Collection<? extends T>) - Method in interface reactor.core.Fuseable.QueueSubscription
addCallSiteInfo(P, String) - Static method in class reactor.core.publisher.Hooks: Deprecated.
Should only be used by the instrumentation, DOES NOT guarantee any compatibility
addCap(long, long) - Static method in class reactor.core.publisher.Operators: Cap an addition to Long.MAX_VALUE
addCap(AtomicLongFieldUpdater<T>, T, long) - Static method in class reactor.core.publisher.Operators: Concurrent addition bound to Long.MAX_VALUE.
addExecutorServiceDecorator(String, BiFunction<Scheduler, ScheduledExecutorService, ScheduledExecutorService>) - Static method in class reactor.core.scheduler.Schedulers: Set up an additional ScheduledExecutorService decorator for a given key only if that key is not already present.
addQueueWrapper(String, Function<Queue<?>, Queue<?>>) - Static method in class reactor.core.publisher.Hooks: Adds a wrapper for every Queue used in Reactor.
addReturnInfo(P, String) - Static method in class reactor.core.publisher.Hooks: Deprecated.
Should only be used by the instrumentation, DOES NOT guarantee any compatibility
addSuppressed(RuntimeException, Throwable) - Static method in class reactor.core.Exceptions: Safely suppress a Throwable on a RuntimeException.
addSuppressed(Throwable, Throwable) - Static method in class reactor.core.Exceptions: Safely suppress a Throwable on an original Throwable.
addThrowable(AtomicReferenceFieldUpdater<T, Throwable>, T, Throwable) - Static method in class reactor.core.Exceptions: Update an empty atomic reference with the given exception, or combine further added exceptions together as suppressed exceptions under a root Throwable with the "Multiple exceptions" message, if the atomic reference already holds one.
addToContext(Context) - Method in interface reactor.core.observability.SignalListener: In some cases, the tap operation should alter the Context exposed by the operator in order to store additional data.
AFTER_TERMINATE - Enum constant in enum reactor.core.publisher.SignalType: A signal when an operator completes
all() - Method in interface reactor.core.publisher.Sinks.MulticastReplaySpec: A Sinks.Many with the following characteristics: Multicast Without Subscriber: all elements pushed to this sink are remembered, even when there is no subscriber. Backpressure : this sink honors downstream demand of individual subscribers. Replaying: all elements pushed to this sink are replayed to new subscribers.
all(int) - Method in interface reactor.core.publisher.Sinks.MulticastReplaySpec: A Sinks.Many with the following characteristics: Multicast Without Subscriber: all elements pushed to this sink are remembered, even when there is no subscriber. Backpressure : this sink honors downstream demand of individual subscribers. Replaying: all elements pushed to this sink are replayed to new subscribers.
all(Predicate<? super T>) - Method in class reactor.core.publisher.Flux: Emit a single boolean true if all values of this sequence match the Predicate.
and(Publisher<?>) - Method in class reactor.core.publisher.Mono: Join the termination signals from this mono and another source into the returned void mono
any(Predicate<? super T>) - Method in class reactor.core.publisher.Flux: Emit a single boolean true if any of the values of this Flux sequence match the predicate.
ANY - Static variable in interface reactor.core.Fuseable: Indicates the QueueSubscription should decide what fusion it performs (input only).
apply(Object) - Method in class reactor.util.function.Tuples
apply(Flux<Long>) - Method in class reactor.util.repeat.RepeatSpec
as(Function<? super Flux<T>, P>) - Method in class reactor.core.publisher.Flux: Transform this Flux into a target type.
as(Function<? super Mono<T>, P>) - Method in class reactor.core.publisher.Mono: Transform this Mono into a target type.
as(Function<? super ParallelFlux<T>, U>) - Method in class reactor.core.publisher.ParallelFlux: Perform a fluent transformation to a value via a converter function which receives this ParallelFlux.
as(Subscription) - Static method in class reactor.core.publisher.Operators: Returns the subscription as QueueSubscription if possible or null.
asFlux() - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.
asFlux() - Method in class reactor.core.publisher.ReplayProcessor: Deprecated.
asFlux() - Method in interface reactor.core.publisher.Sinks.Many: Return a Flux view of this sink.
asFlux() - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
asMono() - Method in class reactor.core.publisher.SinkOneSerialized
asMono() - Method in interface reactor.core.publisher.Sinks.Empty: Return a Mono view of this sink.
ASYNC - Enum constant in enum reactor.core.Scannable.Attr.RunStyle: the operator may change threads while running
ASYNC - Static variable in interface reactor.core.Fuseable: Indicates the QueueSubscription can perform only async-fusion.
Attr(T) - Constructor for class reactor.core.Scannable.Attr
Attr(T, Function<Object, ? extends T>) - Constructor for class reactor.core.Scannable.Attr
AUTO_CLOSE - Static variable in class reactor.core.Exceptions: A general-purpose Consumer that closes AutoCloseable resource.
autoConnect() - Method in class reactor.core.publisher.ConnectableFlux: Connects this ConnectableFlux to the upstream source when the first Subscriber subscribes.
autoConnect(int) - Method in class reactor.core.publisher.ConnectableFlux: Connects this ConnectableFlux to the upstream source when the specified amount of Subscriber subscribes.
autoConnect(int, Consumer<? super Disposable>) - Method in class reactor.core.publisher.ConnectableFlux: Connects this ConnectableFlux to the upstream source when the specified amount of Subscriber subscribes and calls the supplied consumer with a Disposable that allows disconnecting.

B

backoff() - Method in interface reactor.util.repeat.RepeatSpec.RepeatSignal: Returns the delay before the next repeat attempt.
backoff(long, Duration) - Static method in class reactor.util.retry.Retry: A RetryBackoffSpec preconfigured for exponential backoff strategy with jitter, given a maximum number of retry attempts and a minimum Duration for the backoff.
backoffSchedulerSupplier - Variable in class reactor.util.retry.RetryBackoffSpec: The configured Supplier of Scheduler on which to execute backoffs.
BACKPRESSURE_ERROR_QUEUE_FULL - Static variable in class reactor.core.Exceptions: A common error message used when a reactive streams source doesn't seem to respect backpressure signals, resulting in an operator's internal queue to be full.
BaseSubscriber<T> - Class in reactor.core.publisher: A simple base class for a Subscriber implementation that lets the user perform a BaseSubscriber.request(long) and BaseSubscriber.cancel() on it directly.
BaseSubscriber() - Constructor for class reactor.core.publisher.BaseSubscriber
block() - Method in class reactor.core.publisher.Mono: Subscribe to this Mono and block indefinitely until a next signal is received.
block() - Method in class reactor.core.publisher.MonoProcessor: Deprecated.

Block the calling thread indefinitely, waiting for the completion of this MonoProcessor.
block(Duration) - Method in class reactor.core.publisher.MonoProcessor: Deprecated.

Block the calling thread for the specified time, waiting for the completion of this MonoProcessor.
block(Duration) - Method in class reactor.core.publisher.Mono: Subscribe to this Mono and block until a next signal is received or a timeout expires.
blockFirst() - Method in class reactor.core.publisher.Flux: Subscribe to this Flux and block indefinitely until the upstream signals its first value or completes.
blockFirst(Duration) - Method in class reactor.core.publisher.Flux: Subscribe to this Flux and block until the upstream signals its first value, completes or a timeout expires.
blockLast() - Method in class reactor.core.publisher.Flux: Subscribe to this Flux and block indefinitely until the upstream signals its last value or completes.
blockLast(Duration) - Method in class reactor.core.publisher.Flux: Subscribe to this Flux and block until the upstream signals its last value, completes or a timeout expires.
blockOptional() - Method in class reactor.core.publisher.Mono: Subscribe to this Mono and block indefinitely until a next signal is received or the Mono completes empty.
blockOptional(Duration) - Method in class reactor.core.publisher.Mono: Subscribe to this Mono and block until a next signal is received, the Mono completes empty or a timeout expires.
boundedElastic() - Static method in class reactor.core.scheduler.Schedulers: The common boundedElastic instance, a Scheduler that dynamically creates a bounded number of workers.
bubble(Throwable) - Static method in class reactor.core.Exceptions: Prepare an unchecked RuntimeException that will bubble upstream if thrown by an operator.
buffer() - Method in class reactor.core.publisher.Flux: Collect all incoming values into a single List buffer that will be emitted by the returned Flux once this Flux completes.
buffer(int) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple List buffers that will be emitted by the returned Flux each time the given max size is reached or once this Flux completes.
buffer(int, int) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple List buffers that will be emitted by the returned Flux each time the given max size is reached or once this Flux completes.
buffer(int, int, Supplier<C>) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple user-defined Collection buffers that will be emitted by the returned Flux each time the given max size is reached or once this Flux completes.
buffer(int, Supplier<C>) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple user-defined Collection buffers that will be emitted by the returned Flux each time the given max size is reached or once this Flux completes.
buffer(Duration) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple List buffers that will be emitted by the returned Flux every bufferingTimespan.
buffer(Duration, Duration) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple List buffers created at a given openBufferEvery period.
buffer(Duration, Duration, Scheduler) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple List buffers created at a given openBufferEvery period, as measured on the provided Scheduler.
buffer(Duration, Scheduler) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple List buffers that will be emitted by the returned Flux every bufferingTimespan, as measured on the provided Scheduler.
buffer(Publisher<?>) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple List buffers, as delimited by the signals of a companion Publisher this operator will subscribe to.
buffer(Publisher<?>, Supplier<C>) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple user-defined Collection buffers, as delimited by the signals of a companion Publisher this operator will subscribe to.
BUFFER - Enum constant in enum reactor.core.publisher.FluxSink.OverflowStrategy: Buffer all signals if the downstream can't keep up.
BUFFERED - Static variable in class reactor.core.Scannable.Attr: A Integer attribute implemented by components with a backlog capacity.
BufferOverflowStrategy - Enum in reactor.core.publisher: Strategies to deal with overflow of a buffer during backpressure buffering.
bufferTimeout(int, Duration) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple List buffers that will be emitted by the returned Flux each time the buffer reaches a maximum size OR the maxTime Duration elapses.
bufferTimeout(int, Duration, boolean) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple List buffers that will be emitted by the returned Flux each time the buffer reaches a maximum size OR the maxTime Duration elapses.
bufferTimeout(int, Duration, Supplier<C>) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple user-defined Collection buffers that will be emitted by the returned Flux each time the buffer reaches a maximum size OR the maxTime Duration elapses.
bufferTimeout(int, Duration, Supplier<C>, boolean) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple user-defined Collection buffers that will be emitted by the returned Flux each time the buffer reaches a maximum size OR the maxTime Duration elapses.
bufferTimeout(int, Duration, Scheduler) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple List buffers that will be emitted by the returned Flux each time the buffer reaches a maximum size OR the maxTime Duration elapses, as measured on the provided Scheduler.
bufferTimeout(int, Duration, Scheduler, boolean) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple List buffers that will be emitted by the returned Flux each time the buffer reaches a maximum size OR the maxTime Duration elapses, as measured on the provided Scheduler.
bufferTimeout(int, Duration, Scheduler, Supplier<C>) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple user-defined Collection buffers that will be emitted by the returned Flux each time the buffer reaches a maximum size OR the maxTime Duration elapses, as measured on the provided Scheduler.
bufferTimeout(int, Duration, Scheduler, Supplier<C>, boolean) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple user-defined Collection buffers that will be emitted by the returned Flux each time the buffer reaches a maximum size OR the maxTime Duration elapses, as measured on the provided Scheduler.
bufferUntil(Predicate<? super T>) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple List buffers that will be emitted by the resulting Flux each time the given predicate returns true.
bufferUntil(Predicate<? super T>, boolean) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple List buffers that will be emitted by the resulting Flux each time the given predicate returns true.
bufferUntilChanged() - Method in class reactor.core.publisher.Flux: Collect subsequent repetitions of an element (that is, if they arrive right after one another) into multiple List buffers that will be emitted by the resulting Flux.
bufferUntilChanged(Function<? super T, ? extends V>) - Method in class reactor.core.publisher.Flux: Collect subsequent repetitions of an element (that is, if they arrive right after one another), as compared by a key extracted through the user provided Function, into multiple List buffers that will be emitted by the resulting Flux.
bufferUntilChanged(Function<? super T, ? extends V>, BiPredicate<? super V, ? super V>) - Method in class reactor.core.publisher.Flux: Collect subsequent repetitions of an element (that is, if they arrive right after one another), as compared by a key extracted through the user provided Function and compared using a supplied BiPredicate, into multiple List buffers that will be emitted by the resulting Flux.
bufferWhen(Publisher, Function<? super U, ? extends Publisher<V>>) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple List buffers started each time an opening companion Publisher emits.
bufferWhen(Publisher, Function<? super U, ? extends Publisher<V>>, Supplier<C>) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple user-defined Collection buffers started each time an opening companion Publisher emits.
bufferWhile(Predicate<? super T>) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple List buffers that will be emitted by the resulting Flux.
busyLooping(Duration) - Static method in interface reactor.core.publisher.Sinks.EmitFailureHandler: Create an Sinks.EmitFailureHandler which will busy loop in case of concurrent use of the sink (Sinks.EmitResult.FAIL_NON_SERIALIZED, up to a deadline.

C

cache() - Method in class reactor.core.publisher.Flux: Turn this Flux into a hot source and cache last emitted signals for further Subscriber.
cache() - Method in class reactor.core.publisher.Mono: Turn this Mono into a hot source and cache last emitted signals for further Subscriber.
cache(int) - Method in class reactor.core.publisher.Flux: Turn this Flux into a hot source and cache last emitted signals for further Subscriber.
cache(int, Duration) - Method in class reactor.core.publisher.Flux: Turn this Flux into a hot source and cache last emitted signals for further Subscriber.
cache(int, Duration, Scheduler) - Method in class reactor.core.publisher.Flux: Turn this Flux into a hot source and cache last emitted signals for further Subscriber.
cache(Duration) - Method in class reactor.core.publisher.Flux: Turn this Flux into a hot source and cache last emitted signals for further Subscriber.
cache(Duration) - Method in class reactor.core.publisher.Mono: Turn this Mono into a hot source and cache last emitted signals for further Subscriber, with an expiry timeout.
cache(Duration, Scheduler) - Method in class reactor.core.publisher.Flux: Turn this Flux into a hot source and cache last emitted signals for further Subscriber.
cache(Duration, Scheduler) - Method in class reactor.core.publisher.Mono: Turn this Mono into a hot source and cache last emitted signals for further Subscriber, with an expiry timeout.
cache(Function<? super T, Duration>, Function<Throwable, Duration>, Supplier<Duration>) - Method in class reactor.core.publisher.Mono: Turn this Mono into a hot source and cache last emitted signal for further Subscriber, with an expiry timeout (TTL) that depends on said signal.
cache(Function<? super T, Duration>, Function<Throwable, Duration>, Supplier<Duration>, Scheduler) - Method in class reactor.core.publisher.Mono: Turn this Mono into a hot source and cache last emitted signal for further Subscriber, with an expiry timeout (TTL) that depends on said signal.
cacheInvalidateIf(Predicate<? super T>) - Method in class reactor.core.publisher.Mono: Cache onNext signal received from the source and replay it to other subscribers, while allowing invalidation by verifying the cached value against the given Predicate each time a late subscription occurs.
cacheInvalidateWhen(Function<? super T, Mono<Void>>) - Method in class reactor.core.publisher.Mono: Cache onNext signal received from the source and replay it to other subscribers, while allowing invalidation via a Mono<Void> companion trigger generated from the currently cached value.
cacheInvalidateWhen(Function<? super T, Mono<Void>>, Consumer<? super T>) - Method in class reactor.core.publisher.Mono: Cache onNext signal received from the source and replay it to other subscribers, while allowing invalidation via a Mono<Void> companion trigger generated from the currently cached value.
cacheLast() - Static method in class reactor.core.publisher.ReplayProcessor: Deprecated.
use Sinks.many().replay().latest() (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
cacheLastOrDefault(T) - Static method in class reactor.core.publisher.ReplayProcessor: Deprecated.
use Sinks.many().replay().latestOrDefault(value) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
canAppearAfterOnSubscribe(Subscription) - Static method in class reactor.core.publisher.Operators: Check whether the provided Subscription is the one used to satisfy Spec's §1.9 rule before signalling an error.
cancel() - Method in class reactor.core.publisher.BaseSubscriber
cancel() - Method in class reactor.core.publisher.MonoProcessor: Deprecated.
the MonoProcessor will cease to implement Subscription in 3.5
cancel() - Method in class reactor.core.publisher.Operators.DeferredSubscription
cancel() - Method in class reactor.core.publisher.Operators.MonoSubscriber
cancel() - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
CANCEL - Enum constant in enum reactor.core.publisher.SignalType: A signal when the subscription is cancelled
CANCELLED - Static variable in class reactor.core.Scannable.Attr: A Boolean attribute indicating whether or not a downstream component has interrupted consuming this scanned component, e.g., a cancelled subscription.
cancelledSubscription() - Static method in class reactor.core.publisher.Operators: A singleton Subscription that represents a cancelled subscription instance and should not be leaked to clients as it represents a terminal state.
cancelOn(Scheduler) - Method in class reactor.core.publisher.Flux: Prepare this Flux so that subscribers will cancel from it on a specified Scheduler.
cancelOn(Scheduler) - Method in class reactor.core.publisher.Mono: Prepare this Mono so that subscribers will cancel from it on a specified Scheduler.
capacity(Queue) - Static method in class reactor.util.concurrent.Queues: Return the capacity of a given Queue in a best effort fashion.
CAPACITY - Static variable in class reactor.core.Scannable.Attr: Return an an Integer capacity when no Scannable.Attr.PREFETCH is defined or when an arbitrary maximum limit is applied to the backlog capacity of the scanned component.
CAPACITY_UNSURE - Static variable in class reactor.util.concurrent.Queues
cast(Class<E>) - Method in class reactor.core.publisher.Flux: Cast the current Flux produced type into a target produced type.
cast(Class<E>) - Method in class reactor.core.publisher.Mono: Cast the current Mono produced type into a target produced type.
ceilingNextPowerOfTwo(int) - Static method in class reactor.util.concurrent.Queues: Calculate the next power of 2, greater than or equal to x.
checkpoint() - Method in class reactor.core.publisher.Flux: Activate traceback (full assembly tracing) for this particular Flux, in case of an error upstream of the checkpoint.
checkpoint() - Method in class reactor.core.publisher.Mono: Activate traceback (full assembly tracing) for this particular Mono, in case of an error upstream of the checkpoint.
checkpoint() - Method in class reactor.core.publisher.ParallelFlux: Activate traceback (full assembly tracing) for this particular ParallelFlux, in case of an error upstream of the checkpoint.
checkpoint(String, boolean) - Method in class reactor.core.publisher.Flux: Activate traceback (full assembly tracing or the lighter assembly marking depending on the forceStackTrace option).
checkpoint(String, boolean) - Method in class reactor.core.publisher.Mono: Activate traceback (full assembly tracing or the lighter assembly marking depending on the forceStackTrace option).
checkpoint(String) - Method in class reactor.core.publisher.Flux: Activate traceback (assembly marker) for this particular Flux by giving it a description that will be reflected in the assembly traceback in case of an error upstream of the checkpoint.
checkpoint(String) - Method in class reactor.core.publisher.Mono: Activate traceback (assembly marker) for this particular Mono by giving it a description that will be reflected in the assembly traceback in case of an error upstream of the checkpoint.
checkpoint(String) - Method in class reactor.core.publisher.ParallelFlux: Activate traceback (assembly marker) for this particular ParallelFlux by giving it a description that will be reflected in the assembly traceback in case of an error upstream of the checkpoint.
checkpoint(String, boolean) - Method in class reactor.core.publisher.ParallelFlux: Activate traceback (full assembly tracing or the lighter assembly marking depending on the forceStackTrace option).
clear() - Method in class reactor.core.publisher.Operators.MonoSubscriber
clear() - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
collect(Supplier<? extends C>, BiConsumer<? super C, ? super T>) - Method in class reactor.core.publisher.ParallelFlux: Collect the elements in each rail into a collection supplied via a collectionSupplier and collected into with a collector action, emitting the collection at the end.
collect(Supplier<E>, BiConsumer<E, ? super T>) - Method in class reactor.core.publisher.Flux: Collect all elements emitted by this Flux into a user-defined container, by applying a collector BiConsumer taking the container and each element.
collect(Collector<? super T, A, ? extends R>) - Method in class reactor.core.publisher.Flux: Collect all elements emitted by this Flux into a container, by applying a Java 8 Stream API Collector The collected result will be emitted when this sequence completes, emitting the empty container if the sequence was empty.
collectList() - Method in class reactor.core.publisher.Flux: Collect all elements emitted by this Flux into a List that is emitted by the resulting Mono when this sequence completes, emitting the empty List if the sequence was empty.
collectMap(Function<? super T, ? extends K>) - Method in class reactor.core.publisher.Flux: Collect all elements emitted by this Flux into a hashed Map that is emitted by the resulting Mono when this sequence completes, emitting the empty Map if the sequence was empty.
collectMap(Function<? super T, ? extends K>, Function<? super T, ? extends V>) - Method in class reactor.core.publisher.Flux: Collect all elements emitted by this Flux into a hashed Map that is emitted by the resulting Mono when this sequence completes, emitting the empty Map if the sequence was empty.
collectMap(Function<? super T, ? extends K>, Function<? super T, ? extends V>, Supplier<Map<K, V>>) - Method in class reactor.core.publisher.Flux: Collect all elements emitted by this Flux into a user-defined Map that is emitted by the resulting Mono when this sequence completes, emitting the empty Map if the sequence was empty.
collectMultimap(Function<? super T, ? extends K>) - Method in class reactor.core.publisher.Flux: Collect all elements emitted by this Flux into a multimap that is emitted by the resulting Mono when this sequence completes, emitting the empty multimap if the sequence was empty.
collectMultimap(Function<? super T, ? extends K>, Function<? super T, ? extends V>) - Method in class reactor.core.publisher.Flux: Collect all elements emitted by this Flux into a multimap that is emitted by the resulting Mono when this sequence completes, emitting the empty multimap if the sequence was empty.
collectMultimap(Function<? super T, ? extends K>, Function<? super T, ? extends V>, Supplier<Map<K, Collection<V>>>) - Method in class reactor.core.publisher.Flux: Collect all elements emitted by this Flux into a user-defined multimap that is emitted by the resulting Mono when this sequence completes, emitting the empty multimap if the sequence was empty.
collectSortedList() - Method in class reactor.core.publisher.Flux: Collect all elements emitted by this Flux until this sequence completes, and then sort them in natural order into a List that is emitted by the resulting Mono.
collectSortedList(Comparator<? super T>) - Method in class reactor.core.publisher.Flux: Collect all elements emitted by this Flux until this sequence completes, and then sort them using a Comparator into a List that is emitted by the resulting Mono.
collectSortedList(Comparator<? super T>) - Method in class reactor.core.publisher.ParallelFlux: Sorts the 'rails' according to the comparator and returns a full sorted list as a Publisher.
collectSortedList(Comparator<? super T>, int) - Method in class reactor.core.publisher.ParallelFlux: Sorts the 'rails' according to the comparator and returns a full sorted list as a Publisher.
combineLatest(Iterable<? extends Publisher<? extends T>>, int, Function<Object[], V>) - Static method in class reactor.core.publisher.Flux: Build a Flux whose data are generated by the combination of the most recently published value from each of the Publisher sources provided in an Iterable.
combineLatest(Iterable<? extends Publisher<? extends T>>, Function<Object[], V>) - Static method in class reactor.core.publisher.Flux: Build a Flux whose data are generated by the combination of the most recently published value from each of the Publisher sources provided in an Iterable.
combineLatest(Function<Object[], V>, int, Publisher<? extends T>...) - Static method in class reactor.core.publisher.Flux: Build a Flux whose data are generated by the combination of the most recently published value from each of the Publisher sources.
combineLatest(Function<Object[], V>, Publisher<? extends T>...) - Static method in class reactor.core.publisher.Flux: Build a Flux whose data are generated by the combination of the most recently published value from each of the Publisher sources.
combineLatest(Publisher<? extends T1>, Publisher<? extends T2>, BiFunction<? super T1, ? super T2, ? extends V>) - Static method in class reactor.core.publisher.Flux: Build a Flux whose data are generated by the combination of the most recently published value from each of two Publisher sources.
combineLatest(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Function<Object[], V>) - Static method in class reactor.core.publisher.Flux: Build a Flux whose data are generated by the combination of the most recently published value from each of three Publisher sources.
combineLatest(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Publisher<? extends T4>, Function<Object[], V>) - Static method in class reactor.core.publisher.Flux: Build a Flux whose data are generated by the combination of the most recently published value from each of four Publisher sources.
combineLatest(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Publisher<? extends T4>, Publisher<? extends T5>, Function<Object[], V>) - Static method in class reactor.core.publisher.Flux: Build a Flux whose data are generated by the combination of the most recently published value from each of five Publisher sources.
combineLatest(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Publisher<? extends T4>, Publisher<? extends T5>, Publisher<? extends T6>, Function<Object[], V>) - Static method in class reactor.core.publisher.Flux: Build a Flux whose data are generated by the combination of the most recently published value from each of six Publisher sources.
companionValue() - Method in interface reactor.util.repeat.RepeatSpec.RepeatSignal: Returns the value from the companion publisher that triggered this repeat signal.
complete() - Method in interface reactor.core.publisher.FluxSink: Terminate the sequence successfully, generating an onComplete signal.
complete() - Static method in interface reactor.core.publisher.Signal: Creates and returns a Signal of variety Type.COMPLETE.
complete() - Method in interface reactor.core.publisher.SynchronousSink
complete(O) - Method in class reactor.core.publisher.Operators.MonoSubscriber: Tries to emit the value and complete the underlying subscriber or stores the value away until there is a request for it.
complete(Subscriber<?>) - Static method in class reactor.core.publisher.Operators: Calls onSubscribe on the target Subscriber with the empty instance followed by a call to onComplete.
complete(Context) - Static method in interface reactor.core.publisher.Signal: Creates and returns a Signal of variety Type.COMPLETE, associated with a specific Context.
composite() - Static method in class reactor.core.Disposables: Create a new empty Disposable.Composite with atomic guarantees on all mutative operations.
composite(Iterable<? extends Disposable>) - Static method in class reactor.core.Disposables: Create and initialize a new Disposable.Composite with atomic guarantees on all mutative operations.
composite(Disposable...) - Static method in class reactor.core.Disposables: Create and initialize a new Disposable.Composite with atomic guarantees on all mutative operations.
concat(Iterable<? extends Publisher<? extends T>>) - Static method in class reactor.core.publisher.Flux: Concatenate all sources provided in an Iterable, forwarding elements emitted by the sources downstream.
concat(Publisher<? extends Publisher<? extends T>>) - Static method in class reactor.core.publisher.Flux: Concatenate all sources emitted as an onNext signal from a parent Publisher, forwarding elements emitted by the sources downstream.
concat(Publisher<? extends Publisher<? extends T>>, int) - Static method in class reactor.core.publisher.Flux: Concatenate all sources emitted as an onNext signal from a parent Publisher, forwarding elements emitted by the sources downstream.
concat(Publisher<? extends T>...) - Static method in class reactor.core.publisher.Flux: Concatenate all sources provided as a vararg, forwarding elements emitted by the sources downstream.
concatDelayError(Publisher<? extends Publisher<? extends T>>) - Static method in class reactor.core.publisher.Flux: Concatenate all sources emitted as an onNext signal from a parent Publisher, forwarding elements emitted by the sources downstream.
concatDelayError(Publisher<? extends Publisher<? extends T>>, boolean, int) - Static method in class reactor.core.publisher.Flux: Concatenate all sources emitted as an onNext signal from a parent Publisher, forwarding elements emitted by the sources downstream.
concatDelayError(Publisher<? extends Publisher<? extends T>>, int) - Static method in class reactor.core.publisher.Flux: Concatenate all sources emitted as an onNext signal from a parent Publisher, forwarding elements emitted by the sources downstream.
concatDelayError(Publisher<? extends T>...) - Static method in class reactor.core.publisher.Flux: Concatenate all sources provided as a vararg, forwarding elements emitted by the sources downstream.
concatMap(Function<? super T, ? extends Publisher<? extends R>>) - Method in class reactor.core.publisher.ParallelFlux: Generates and concatenates Publishers on each 'rail', signalling errors immediately and generating 2 publishers upfront.
concatMap(Function<? super T, ? extends Publisher<? extends R>>, int) - Method in class reactor.core.publisher.ParallelFlux: Generates and concatenates Publishers on each 'rail', signalling errors immediately and using the given prefetch amount for generating Publishers upfront.
concatMap(Function<? super T, ? extends Publisher<? extends V>>) - Method in class reactor.core.publisher.Flux: Transform the elements emitted by this Flux asynchronously into Publishers, then flatten these inner publishers into a single Flux, sequentially and preserving order using concatenation.
concatMap(Function<? super T, ? extends Publisher<? extends V>>, int) - Method in class reactor.core.publisher.Flux: Transform the elements emitted by this Flux asynchronously into Publishers, then flatten these inner publishers into a single Flux, sequentially and preserving order using concatenation.
concatMapDelayError(Function<? super T, ? extends Publisher<? extends R>>) - Method in class reactor.core.publisher.ParallelFlux: Generates and concatenates Publishers on each 'rail', delaying errors and generating 2 publishers upfront.
concatMapDelayError(Function<? super T, ? extends Publisher<? extends V>>) - Method in class reactor.core.publisher.Flux: Transform the elements emitted by this Flux asynchronously into Publishers, then flatten these inner publishers into a single Flux, sequentially and preserving order using concatenation.
concatMapDelayError(Function<? super T, ? extends Publisher<? extends V>>, boolean, int) - Method in class reactor.core.publisher.Flux: Transform the elements emitted by this Flux asynchronously into Publishers, then flatten these inner publishers into a single Flux, sequentially and preserving order using concatenation.
concatMapDelayError(Function<? super T, ? extends Publisher<? extends V>>, int) - Method in class reactor.core.publisher.Flux: Transform the elements emitted by this Flux asynchronously into Publishers, then flatten these inner publishers into a single Flux, sequentially and preserving order using concatenation.
concatMapIterable(Function<? super T, ? extends Iterable<? extends R>>) - Method in class reactor.core.publisher.Flux: Transform the items emitted by this Flux into Iterable, then flatten the elements from those by concatenating them into a single Flux.
concatMapIterable(Function<? super T, ? extends Iterable<? extends R>>, int) - Method in class reactor.core.publisher.Flux: Transform the items emitted by this Flux into Iterable, then flatten the emissions from those by concatenating them into a single Flux.
concatWith(Publisher<? extends T>) - Method in class reactor.core.publisher.Flux: Concatenate emissions of this Flux with the provided Publisher (no interleave).
concatWith(Publisher<? extends T>) - Method in class reactor.core.publisher.Mono: Concatenate emissions of this Mono with the provided Publisher (no interleave).
concatWithValues(T...) - Method in class reactor.core.publisher.Flux: Concatenates the values to the end of the Flux
connect() - Method in class reactor.core.publisher.ConnectableFlux: Connect this ConnectableFlux to its source and return a Disposable that can be used for disconnecting.
connect(Consumer<? super Disposable>) - Method in class reactor.core.publisher.ConnectableFlux: Connects this ConnectableFlux to its source and sends a Disposable to a callback that can be used for disconnecting.
ConnectableFlux<T> - Class in reactor.core.publisher: The abstract base class for connectable publishers that let subscribers pile up before they connect to their data source.
ConnectableFlux() - Constructor for class reactor.core.publisher.ConnectableFlux
contains(Object) - Method in interface reactor.core.Fuseable.QueueSubscription
containsAll(Collection<?>) - Method in interface reactor.core.Fuseable.QueueSubscription
Context - Interface in reactor.util.context: A key/value store that is propagated between components such as operators via the context protocol.
contextCapture() - Method in class reactor.core.publisher.Flux: If context-propagation library is on the classpath, this is a convenience shortcut to capture thread local values during the subscription phase and put them in the Context that is visible upstream of this operator.
contextCapture() - Method in class reactor.core.publisher.Mono: If context-propagation library is on the classpath, this is a convenience shortcut to capture thread local values during the subscription phase and put them in the Context that is visible upstream of this operator.
contextView() - Method in interface reactor.core.publisher.FluxSink: Return the current subscriber's context as a ContextView for inspection.
contextView() - Method in interface reactor.core.publisher.MonoSink: Return the current subscriber's context as a ContextView for inspection.
contextView() - Method in interface reactor.core.publisher.SynchronousSink: Return the current subscriber's context as a ContextView for inspection.
ContextView - Interface in reactor.util.context: A read-only view of a collection of key/value pairs that is propagated between components such as operators via the context protocol.
contextWrite(Function<Context, Context>) - Method in class reactor.core.publisher.Flux: Enrich the Context visible from downstream for the benefit of upstream operators, by applying a Function to the downstream Context.
contextWrite(Function<Context, Context>) - Method in class reactor.core.publisher.Mono: Enrich the Context visible from downstream for the benefit of upstream operators, by applying a Function to the downstream Context.
contextWrite(ContextView) - Method in class reactor.core.publisher.Flux: Enrich the Context visible from downstream for the benefit of upstream operators, by making all values from the provided ContextView visible on top of pairs from downstream.
contextWrite(ContextView) - Method in class reactor.core.publisher.Mono: Enrich the Context visible from downstream for the benefit of upstream operators, by making all values from the provided ContextView visible on top of pairs from downstream.
convertToFluxBypassingHooks(Publisher<T>) - Static method in class reactor.core.publisher.Hooks: Utility method to convert a Publisher to a Flux without applying Hooks.
convertToMonoBypassingHooks(Publisher<T>, boolean) - Static method in class reactor.core.publisher.Hooks: Utility method to convert a Publisher to a Mono without applying Hooks.
copy() - Method in interface reactor.util.repeat.RepeatSpec.RepeatSignal: Returns an immutable copy of this RepeatSpec.RepeatSignal, capturing the current state.
copy() - Method in interface reactor.util.retry.Retry.RetrySignal: An immutable copy of this Retry.RetrySignal which is guaranteed to give a consistent view of the state at the time at which this method is invoked.
CorePublisher<T> - Interface in reactor.core: A CoreSubscriber aware publisher.
CoreSubscriber<T> - Interface in reactor.core: A Context aware subscriber which has relaxed rules for §1.3 and §3.9 compared to the original Subscriber from Reactive Streams.
count() - Method in class reactor.core.publisher.Flux: Counts the number of values in this Flux.
create() - Static method in class reactor.core.publisher.DirectProcessor: Deprecated.
To be removed in 3.5. Closest sink is Sinks.many().multicast().directBestEffort(), except it doesn't terminate overflowing downstreams.
create() - Static method in class reactor.core.publisher.EmitterProcessor: Deprecated.
use Sinks.many().multicast().onBackpressureBuffer() (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
create() - Static method in class reactor.core.publisher.MonoProcessor: Deprecated.
Use Sinks.one(), to be removed in 3.5
create() - Static method in class reactor.core.publisher.ReplayProcessor: Deprecated.
use Sinks.many().replay().all() (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
create() - Static method in class reactor.core.publisher.UnicastProcessor: Deprecated.
use Sinks.many().unicast().onBackpressureBuffer() (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
create(boolean) - Static method in class reactor.core.publisher.EmitterProcessor: Deprecated.
use Sinks.many().multicast().onBackpressureBuffer(bufferSize, boolean) using the old default of Queues.SMALL_BUFFER_SIZE for the bufferSize (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
create(int) - Static method in class reactor.core.publisher.EmitterProcessor: Deprecated.
use Sinks.many().multicast().onBackpressureBuffer(bufferSize) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
create(int) - Static method in class reactor.core.publisher.ReplayProcessor: Deprecated.
use Sinks.many().replay().limit(historySize) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
create(int, boolean) - Static method in class reactor.core.publisher.EmitterProcessor: Deprecated.
use Sinks.many().multicast().onBackpressureBuffer(bufferSize, autoCancel) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
create(int, boolean) - Static method in class reactor.core.publisher.ReplayProcessor: Deprecated.
use Sinks.many().replay().limit(historySize) for bounded cases (unbounded == false) or Sinks.many().replay().all(bufferSize) otherwise (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
create(Consumer<? super FluxSink<T>>) - Static method in class reactor.core.publisher.Flux: Programmatically create a Flux with the capability of emitting multiple elements in a synchronous or asynchronous manner through the FluxSink API.
create(Consumer<? super FluxSink<T>>, FluxSink.OverflowStrategy) - Static method in class reactor.core.publisher.Flux: Programmatically create a Flux with the capability of emitting multiple elements in a synchronous or asynchronous manner through the FluxSink API.
create(Consumer<MonoSink<T>>) - Static method in class reactor.core.publisher.Mono: Creates a deferred emitter that can be used with callback-based APIs to signal at most one value, a complete or an error signal.
create(Predicate<RepeatSpec.RepeatSignal>, long) - Static method in class reactor.util.repeat.RepeatSpec: Creates a RepeatSpec that repeats n times, only if the predicate returns true.
create(Queue<E>) - Static method in class reactor.core.publisher.UnicastProcessor: Deprecated.
use Sinks.many().unicast().onBackpressureBuffer(queue) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
create(Queue<E>, Consumer<? super E>, Disposable) - Static method in class reactor.core.publisher.UnicastProcessor: Deprecated.
use Sinks.many().unicast().onBackpressureBuffer(queue, endCallback) (or the unsafe variant if you're sure about external synchronization). The onOverflow callback is not supported anymore. To be removed in 3.5.
create(Queue<E>, Disposable) - Static method in class reactor.core.publisher.UnicastProcessor: Deprecated.
use Sinks.many().unicast().onBackpressureBuffer(queue, endCallback) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
createListener(Publisher<? extends T>, ContextView, STATE) - Method in interface reactor.core.observability.SignalListenerFactory: Create a new SignalListener each time a new Subscriber subscribes to the source Publisher.
createSizeAndTimeout(int, Duration) - Static method in class reactor.core.publisher.ReplayProcessor: Deprecated.
use Sinks.many().replay().limit(size, maxAge) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
createSizeAndTimeout(int, Duration, Scheduler) - Static method in class reactor.core.publisher.ReplayProcessor: Deprecated.
use Sinks.many().replay().limit(size, maxAge, scheduler) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
createTimeout(Duration) - Static method in class reactor.core.publisher.ReplayProcessor: Deprecated.
use Sinks.many().replay().limit(maxAge) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
createTimeout(Duration, Scheduler) - Static method in class reactor.core.publisher.ReplayProcessor: Deprecated.
use Sinks.many().replay().limit(maxAge, scheduler) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
createWorker() - Method in interface reactor.core.scheduler.Scheduler: Creates a worker of this Scheduler.
CURRENT_CONTEXT - Enum constant in enum reactor.core.publisher.SignalType: A context read signal
currentContext() - Method in interface reactor.core.CoreSubscriber: Request a Context from dependent components which can include downstream operators during subscribing or a terminal Subscriber.
currentContext() - Method in class reactor.core.publisher.SinkOneSerialized: Request a Context from dependent components which can include downstream operators during subscribing or a terminal Subscriber.
currentContext() - Method in class reactor.core.publisher.DirectProcessor: Deprecated.
currentContext() - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.
currentContext() - Method in class reactor.core.publisher.FluxProcessor: Deprecated.
currentContext() - Method in interface reactor.core.publisher.FluxSink: Deprecated.
To be removed in 3.6.0 at the earliest. Prefer using #contextView() instead.
currentContext() - Method in class reactor.core.publisher.Operators.MonoSubscriber
currentContext() - Method in class reactor.core.publisher.MonoProcessor: Deprecated.
currentContext() - Method in interface reactor.core.publisher.MonoSink: Deprecated.
To be removed in 3.6.0 at the earliest. Prefer using #contextView() instead.
currentContext() - Method in class reactor.core.publisher.ReplayProcessor: Deprecated.
currentContext() - Method in class reactor.core.publisher.SinkOneSerialized
currentContext() - Method in interface reactor.core.publisher.SynchronousSink: Deprecated.
To be removed in 3.6.0 at the earliest. Prefer using #contextView() instead.
currentContext() - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
currentSubscriberCount() - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.
currentSubscriberCount() - Method in class reactor.core.publisher.ReplayProcessor: Deprecated.
currentSubscriberCount() - Method in class reactor.core.publisher.SinkOneSerialized
currentSubscriberCount() - Method in interface reactor.core.publisher.Sinks.Empty: Get how many Subscribers are currently subscribed to the sink.
currentSubscriberCount() - Method in interface reactor.core.publisher.Sinks.Many: Get how many Subscribers are currently subscribed to the sink.
currentSubscriberCount() - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.

D

debug(String) - Method in interface reactor.util.Logger: Log a message at the DEBUG level.
debug(String, Object...) - Method in interface reactor.util.Logger: Log a message at the DEBUG level according to the specified format and arguments.
debug(String, Throwable) - Method in interface reactor.util.Logger: Log an exception (throwable) at the DEBUG level with an accompanying message.
decorateExecutorService(Scheduler, ScheduledExecutorService) - Static method in class reactor.core.scheduler.Schedulers: This method is aimed at Scheduler implementors, enabling custom implementations that are backed by a ScheduledExecutorService to also have said executors decorated (ie.
DEFAULT_BOUNDED_ELASTIC_ON_VIRTUAL_THREADS - Static variable in class reactor.core.scheduler.Schedulers: Default execution of enqueued tasks on Thread#ofVirtual for the global Schedulers.boundedElastic() Scheduler, initialized by system property reactor.schedulers.defaultBoundedElasticOnVirtualThreads and falls back to false .
DEFAULT_BOUNDED_ELASTIC_QUEUESIZE - Static variable in class reactor.core.scheduler.Schedulers: Default maximum number of enqueued tasks PER THREAD for the global Schedulers.boundedElastic() Scheduler, initialized by system property reactor.schedulers.defaultBoundedElasticQueueSize and falls back to a bound of 100 000 tasks per backing thread.
DEFAULT_BOUNDED_ELASTIC_SIZE - Static variable in class reactor.core.scheduler.Schedulers: Default maximum size for the global Schedulers.boundedElastic() Scheduler, initialized by system property reactor.schedulers.defaultBoundedElasticSize and falls back to 10 x number of processors available to the runtime on init.
DEFAULT_POOL_SIZE - Static variable in class reactor.core.scheduler.Schedulers: Default pool size, initialized by system property reactor.schedulers.defaultPoolSize and falls back to the number of processors available to the runtime on init.
defaultIfEmpty(T) - Method in class reactor.core.publisher.Flux: Provide a default unique value if this sequence is completed without any data
defaultIfEmpty(T) - Method in class reactor.core.publisher.Mono: Provide a default single value if this mono is completed without any data
DefaultSignalListener<T> - Class in reactor.core.observability: A default implementation of a SignalListener with all the handlers no-op.
DefaultSignalListener() - Constructor for class reactor.core.observability.DefaultSignalListener
defaultValue() - Method in class reactor.core.Scannable.Attr: Meaningful and always applicable default value for the attribute, returned instead of null when a specific value hasn't been defined for a component.
defer(Supplier<? extends Publisher<T>>) - Static method in class reactor.core.publisher.Flux: Lazily supply a Publisher every time a Subscription is made on the resulting Flux, so the actual source instantiation is deferred until each subscribe and the Supplier can create a subscriber-specific instance.
defer(Supplier<? extends Mono<? extends T>>) - Static method in class reactor.core.publisher.Mono: Create a Mono provider that will supply a target Mono to subscribe to for each Subscriber downstream.
deferContextual(Function<ContextView, ? extends Publisher<T>>) - Static method in class reactor.core.publisher.Flux: Lazily supply a Publisher every time a Subscription is made on the resulting Flux, so the actual source instantiation is deferred until each subscribe and the Function can create a subscriber-specific instance.
deferContextual(Function<ContextView, ? extends Mono<? extends T>>) - Static method in class reactor.core.publisher.Mono: Create a Mono provider that will supply a target Mono to subscribe to for each Subscriber downstream.
DeferredSubscription() - Constructor for class reactor.core.publisher.Operators.DeferredSubscription
delay(Duration) - Static method in class reactor.core.publisher.Mono: Create a Mono which delays an onNext signal by a given duration on a default Scheduler and completes.
delay(Duration, Scheduler) - Static method in class reactor.core.publisher.Mono: Create a Mono which delays an onNext signal by a given duration on a provided Scheduler and completes.
DELAY_ERROR - Static variable in class reactor.core.Scannable.Attr: Delay_Error exposes a Boolean whether the scanned component actively supports error delaying if it manages a backlog instead of fast error-passing which might drop pending backlog.
delayElement(Duration) - Method in class reactor.core.publisher.Mono: Delay this Mono element (Subscriber.onNext(T) signal) by a given duration.
delayElement(Duration, Scheduler) - Method in class reactor.core.publisher.Mono: Delay this Mono element (Subscriber.onNext(T) signal) by a given Duration, on a particular Scheduler.
delayElements(Duration) - Method in class reactor.core.publisher.Flux: Delay each of this Flux elements (Subscriber.onNext(T) signals) by a given Duration.
delayElements(Duration, Scheduler) - Method in class reactor.core.publisher.Flux: Delay each of this Flux elements (Subscriber.onNext(T) signals) by a given Duration.
delaySequence(Duration) - Method in class reactor.core.publisher.Flux: Shift this Flux forward in time by a given Duration.
delaySequence(Duration, Scheduler) - Method in class reactor.core.publisher.Flux: Shift this Flux forward in time by a given Duration.
delaySubscription(Duration) - Method in class reactor.core.publisher.Flux: Delay the subscription to this Flux source until the given period elapses.
delaySubscription(Duration) - Method in class reactor.core.publisher.Mono: Delay the subscription to this Mono source until the given period elapses.
delaySubscription(Duration, Scheduler) - Method in class reactor.core.publisher.Flux: Delay the subscription to this Flux source until the given period elapses, as measured on the user-provided Scheduler.
delaySubscription(Duration, Scheduler) - Method in class reactor.core.publisher.Mono: Delay the subscription to this Mono source until the given Duration elapses.
delaySubscription(Publisher) - Method in class reactor.core.publisher.Flux: Delay the subscription to this Flux source until another Publisher signals a value or completes.
delaySubscription(Publisher) - Method in class reactor.core.publisher.Mono: Delay the subscription to this Mono until another Publisher signals a value or completes.
delayUntil(Function<? super T, ? extends Publisher<?>>) - Method in class reactor.core.publisher.Flux: Subscribe to this Flux and generate a Publisher from each of this Flux elements, each acting as a trigger for relaying said element.
delayUntil(Function<? super T, ? extends Publisher<?>>) - Method in class reactor.core.publisher.Mono: Subscribe to this Mono and another Publisher that is generated from this Mono's element and which will be used as a trigger for relaying said element.
delete(Object) - Method in interface reactor.util.context.Context: Return a new Context that will resolve all existing keys except the removed one, key.
dematerialize() - Method in class reactor.core.publisher.Flux: An operator working only if this Flux emits onNext, onError or onComplete Signal instances, transforming these materialized signals into real signals on the Subscriber.
dematerialize() - Method in class reactor.core.publisher.Mono: An operator working only if this Mono emits onNext, onError or onComplete Signal instances, transforming these materialized signals into real signals on the Subscriber.
directAllOrNothing() - Method in interface reactor.core.publisher.Sinks.MulticastSpec: A Sinks.Many with the following characteristics: Multicast Without Subscriber: fail fast on tryEmitNext. Backpressure : notify the caller with Sinks.EmitResult.FAIL_OVERFLOW if any of the subscribers cannot process an element, failing fast and backing off from emitting the element at all (all or nothing).
directBestEffort() - Method in interface reactor.core.publisher.Sinks.MulticastSpec: A Sinks.Many with the following characteristics: Multicast Without Subscriber: fail fast on tryEmitNext. Backpressure : notify the caller with Sinks.EmitResult.FAIL_OVERFLOW if none of the subscribers can process an element.
DirectProcessor<T> - Class in reactor.core.publisher: Deprecated.
To be removed in 3.5, prefer clear cut usage of Sinks. Closest sink is Sinks.many().multicast().directBestEffort(), except it doesn't terminate overflowing downstreams.
disableAutomaticContextPropagation() - Static method in class reactor.core.publisher.Hooks: Globally disables automatic context propagation to ThreadLocals.
disableContextLossTracking() - Static method in class reactor.core.publisher.Hooks: Globally disables the Context loss detection that was previously enabled by Hooks.enableContextLossTracking().
disableMetrics() - Static method in class reactor.core.scheduler.Schedulers: Deprecated.
prefer using Micrometer#timedScheduler from the reactor-core-micrometer module. To be removed at the earliest in 3.6.0.
discard(O) - Method in class reactor.core.publisher.Operators.MonoSubscriber: Discard the given value, generally this.value field.
Disposable - Interface in reactor.core: Indicates that a task or resource can be cancelled/disposed.
Disposable.Composite - Interface in reactor.core: A container of Disposable that is itself Disposable.
Disposable.Swap - Interface in reactor.core: A Disposable container that allows updating/replacing its inner Disposable atomically and with respect of disposing the container itself.
Disposables - Class in reactor.core: A support class that offers factory methods for implementations of the specialized Disposable sub-interfaces (Disposable.Composite, Disposable.Swap).
dispose() - Method in interface reactor.core.Disposable.Composite: Atomically mark the container as disposed, clear it and then dispose all the previously contained Disposables.
dispose() - Method in interface reactor.core.Disposable: Cancel or dispose the underlying task or resource.
dispose() - Method in class reactor.core.publisher.BaseSubscriber: Dispose the Subscription by cancelling it.
dispose() - Method in class reactor.core.publisher.FluxProcessor: Deprecated.
dispose() - Method in class reactor.core.publisher.MonoProcessor: Deprecated.
dispose() - Method in interface reactor.core.scheduler.Scheduler: Instructs this Scheduler to release all resources and reject any new tasks to be executed.
dispose() - Method in class reactor.core.scheduler.Schedulers.Snapshot
disposed() - Static method in class reactor.core.Disposables: Return a new Disposable that is already disposed.
disposeGracefully() - Method in interface reactor.core.scheduler.Scheduler: Lazy variant of Scheduler.dispose() that also allows for graceful cleanup of underlying resources.
distinct() - Method in class reactor.core.publisher.Flux: For each Subscriber, track elements from this Flux that have been seen and filter out duplicates.
distinct(Function<? super T, ? extends V>) - Method in class reactor.core.publisher.Flux: For each Subscriber, track elements from this Flux that have been seen and filter out duplicates, as compared by a key extracted through the user provided Function.
distinct(Function<? super T, ? extends V>, Supplier<C>) - Method in class reactor.core.publisher.Flux: For each Subscriber, track elements from this Flux that have been seen and filter out duplicates, as compared by a key extracted through the user provided Function and by the add method of the Collection supplied (typically a Set).
distinct(Function<? super T, ? extends V>, Supplier<C>, BiPredicate<C, V>, Consumer<C>) - Method in class reactor.core.publisher.Flux: For each Subscriber, track elements from this Flux that have been seen and filter out duplicates, as compared by applying a BiPredicate on an arbitrary user-supplied <C> store and a key extracted through the user provided Function.
distinctUntilChanged() - Method in class reactor.core.publisher.Flux: Filter out subsequent repetitions of an element (that is, if they arrive right after one another).
distinctUntilChanged(Function<? super T, ? extends V>) - Method in class reactor.core.publisher.Flux: Filter out subsequent repetitions of an element (that is, if they arrive right after one another), as compared by a key extracted through the user provided Function using equality.
distinctUntilChanged(Function<? super T, ? extends V>, BiPredicate<? super V, ? super V>) - Method in class reactor.core.publisher.Flux: Filter out subsequent repetitions of an element (that is, if they arrive right after one another), as compared by a key extracted through the user provided Function and then comparing keys with the supplied BiPredicate.
doAfterComplete() - Method in class reactor.core.observability.DefaultSignalListener
doAfterComplete() - Method in interface reactor.core.observability.SignalListener: Handle graceful onComplete sequence termination, after onComplete has been propagated downstream.
doAfterError(Throwable) - Method in class reactor.core.observability.DefaultSignalListener
doAfterError(Throwable) - Method in interface reactor.core.observability.SignalListener: Handle onError sequence termination after onError has been propagated downstream.
doAfterRepeat(Consumer<RepeatSpec.RepeatSignal>) - Method in class reactor.util.repeat.RepeatSpec: Adds a synchronous doAfterRepeat to be executed after the repeat trigger has completed.
doAfterRetry(Consumer<Retry.RetrySignal>) - Method in class reactor.util.retry.RetryBackoffSpec: Add synchronous behavior to be executed after the retry trigger is emitted in the companion publisher.
doAfterRetry(Consumer<Retry.RetrySignal>) - Method in class reactor.util.retry.RetrySpec: Add synchronous behavior to be executed after the retry trigger is emitted in the companion publisher.
doAfterRetryAsync(Function<Retry.RetrySignal, Mono<Void>>) - Method in class reactor.util.retry.RetryBackoffSpec: Add asynchronous behavior to be executed after the current retry trigger in the companion publisher, thus delaying the resulting retry trigger with the additional Mono.
doAfterRetryAsync(Function<Retry.RetrySignal, Mono<Void>>) - Method in class reactor.util.retry.RetrySpec: Add asynchronous behavior to be executed after the current retry trigger in the companion publisher, thus delaying the resulting retry trigger with the additional Mono.
doAfterTerminate(Runnable) - Method in class reactor.core.publisher.Flux: Add behavior (side-effect) triggered after the Flux terminates, either by completing downstream successfully or with an error.
doAfterTerminate(Runnable) - Method in class reactor.core.publisher.Mono: Add behavior (side-effect) triggered after the Mono terminates, either by completing downstream successfully or with an error.
doAfterTerminate(Runnable) - Method in class reactor.core.publisher.ParallelFlux: Run the specified runnable when a 'rail' completes or signals an error.
doBeforeRepeat(Consumer<RepeatSpec.RepeatSignal>) - Method in class reactor.util.repeat.RepeatSpec: Adds a synchronous doBeforeRepeat to be executed before the repeat trigger.
doBeforeRetry(Consumer<Retry.RetrySignal>) - Method in class reactor.util.retry.RetryBackoffSpec: Add synchronous behavior to be executed before the retry trigger is emitted in the companion publisher.
doBeforeRetry(Consumer<Retry.RetrySignal>) - Method in class reactor.util.retry.RetrySpec: Add synchronous behavior to be executed before the retry trigger is emitted in the companion publisher.
doBeforeRetryAsync(Function<Retry.RetrySignal, Mono<Void>>) - Method in class reactor.util.retry.RetryBackoffSpec: Add asynchronous behavior to be executed before the current retry trigger in the companion publisher, thus delaying the resulting retry trigger with the additional Mono.
doBeforeRetryAsync(Function<Retry.RetrySignal, Mono<Void>>) - Method in class reactor.util.retry.RetrySpec: Add asynchronous behavior to be executed before the current retry trigger in the companion publisher, thus delaying the resulting retry trigger with the additional Mono.
doFinally(Consumer<SignalType>) - Method in class reactor.core.publisher.Flux: Add behavior (side-effect) triggered after the Flux terminates for any reason, including cancellation.
doFinally(Consumer<SignalType>) - Method in class reactor.core.publisher.Mono: Add behavior triggering after the Mono terminates for any reason, including cancellation.
doFinally(SignalType) - Method in class reactor.core.observability.DefaultSignalListener
doFinally(SignalType) - Method in interface reactor.core.observability.SignalListener: Handle terminal signals after the signals have been propagated, as the final step.
doFirst() - Method in class reactor.core.observability.DefaultSignalListener
doFirst() - Method in interface reactor.core.observability.SignalListener: Handle the very beginning of the Subscriber-Publisher interaction.
doFirst(Runnable) - Method in class reactor.core.publisher.Flux: Add behavior (side-effect) triggered before the Flux is subscribed to, which should be the first event after assembly time.
doFirst(Runnable) - Method in class reactor.core.publisher.Mono: Add behavior (side-effect) triggered before the Mono is subscribed to, which should be the first event after assembly time.
doOnCancel() - Method in class reactor.core.observability.DefaultSignalListener
doOnCancel() - Method in interface reactor.core.observability.SignalListener: Handle the downstream cancelling its currently observed Subscription.
doOnCancel(Runnable) - Method in class reactor.core.publisher.Flux: Add behavior (side-effect) triggered when the Flux is cancelled.
doOnCancel(Runnable) - Method in class reactor.core.publisher.Mono: Add behavior triggered when the Mono is cancelled.
doOnCancel(Runnable) - Method in class reactor.core.publisher.ParallelFlux: Run the specified runnable when a 'rail' receives a cancellation.
doOnComplete() - Method in class reactor.core.observability.DefaultSignalListener
doOnComplete() - Method in interface reactor.core.observability.SignalListener: Handle graceful onComplete sequence termination.
doOnComplete(Runnable) - Method in class reactor.core.publisher.Flux: Add behavior (side-effect) triggered when the Flux completes successfully.
doOnComplete(Runnable) - Method in class reactor.core.publisher.ParallelFlux: Run the specified runnable when a 'rail' completes.
doOnDiscard(Class<R>, Consumer<? super R>) - Method in class reactor.core.publisher.Flux: Potentially modify the behavior of the whole chain of operators upstream of this one to conditionally clean up elements that get discarded by these operators.
doOnDiscard(Class<R>, Consumer<? super R>) - Method in class reactor.core.publisher.Mono: Potentially modify the behavior of the whole chain of operators upstream of this one to conditionally clean up elements that get discarded by these operators.
doOnEach(Consumer<? super Signal<T>>) - Method in class reactor.core.publisher.Flux: Add behavior (side-effects) triggered when the Flux emits an item, fails with an error or completes successfully.
doOnEach(Consumer<? super Signal<T>>) - Method in class reactor.core.publisher.Mono: Add behavior triggered when the Mono emits an item, fails with an error or completes successfully.
doOnEach(Consumer<? super Signal<T>>) - Method in class reactor.core.publisher.ParallelFlux: Triggers side-effects when the ParallelFlux emits an item, fails with an error or completes successfully.
doOnError(Class<E>, Consumer<? super E>) - Method in class reactor.core.publisher.Flux: Add behavior (side-effect) triggered when the Flux completes with an error matching the given exception type.
doOnError(Class<E>, Consumer<? super E>) - Method in class reactor.core.publisher.Mono: Add behavior triggered when the Mono completes with an error matching the given exception type.
doOnError(Throwable) - Method in class reactor.core.observability.DefaultSignalListener
doOnError(Throwable) - Method in interface reactor.core.observability.SignalListener: Handle onError sequence termination.
doOnError(Consumer<? super Throwable>) - Method in class reactor.core.publisher.Flux: Add behavior (side-effect) triggered when the Flux completes with an error.
doOnError(Consumer<? super Throwable>) - Method in class reactor.core.publisher.Mono: Add behavior triggered when the Mono completes with an error.
doOnError(Consumer<? super Throwable>) - Method in class reactor.core.publisher.ParallelFlux: Call the specified consumer with the exception passing through any 'rail'.
doOnError(Predicate<? super Throwable>, Consumer<? super Throwable>) - Method in class reactor.core.publisher.Flux: Add behavior (side-effect) triggered when the Flux completes with an error matching the given exception.
doOnError(Predicate<? super Throwable>, Consumer<? super Throwable>) - Method in class reactor.core.publisher.Mono: Add behavior triggered when the Mono completes with an error matching the given predicate.
doOnFusion(int) - Method in class reactor.core.observability.DefaultSignalListener
doOnFusion(int) - Method in interface reactor.core.observability.SignalListener: Handle the negotiation of fusion between two Fuseable operators.
doOnMalformedOnComplete() - Method in class reactor.core.observability.DefaultSignalListener
doOnMalformedOnComplete() - Method in interface reactor.core.observability.SignalListener: Handle malformed Subscriber.onComplete(), which means the sequence has already terminated via Subscriber.onComplete() or Subscriber.onError(Throwable).
doOnMalformedOnError(Throwable) - Method in class reactor.core.observability.DefaultSignalListener
doOnMalformedOnError(Throwable) - Method in interface reactor.core.observability.SignalListener: Handle malformed Subscriber.onError(Throwable), which means the sequence has already terminated via Subscriber.onComplete() or Subscriber.onError(Throwable).
doOnMalformedOnNext(T) - Method in class reactor.core.observability.DefaultSignalListener
doOnMalformedOnNext(T) - Method in interface reactor.core.observability.SignalListener: Handle malformed Subscriber.onNext(Object), which are onNext happening after the sequence has already terminated via Subscriber.onComplete() or Subscriber.onError(Throwable).
doOnNext(Consumer<? super T>) - Method in class reactor.core.publisher.Flux: Add behavior (side-effect) triggered when the Flux emits an item.
doOnNext(Consumer<? super T>) - Method in class reactor.core.publisher.Mono: Add behavior triggered when the Mono emits a data successfully.
doOnNext(Consumer<? super T>) - Method in class reactor.core.publisher.ParallelFlux: Call the specified consumer with the current element passing through any 'rail'.
doOnNext(T) - Method in class reactor.core.observability.DefaultSignalListener
doOnNext(T) - Method in interface reactor.core.observability.SignalListener: Handle a new value emission from the source.
doOnRequest(long) - Method in class reactor.core.observability.DefaultSignalListener
doOnRequest(long) - Method in interface reactor.core.observability.SignalListener: Handle a new request made by the downstream, exposing the demand.
doOnRequest(LongConsumer) - Method in class reactor.core.publisher.Flux: Add behavior (side-effect) triggering a LongConsumer when this Flux receives any request.
doOnRequest(LongConsumer) - Method in class reactor.core.publisher.Mono: Add behavior triggering a LongConsumer when the Mono receives any request.
doOnRequest(LongConsumer) - Method in class reactor.core.publisher.ParallelFlux: Call the specified consumer with the request amount if any rail receives a request.
doOnSubscribe(Consumer<? super Subscription>) - Method in class reactor.core.publisher.Flux: Add behavior (side-effect) triggered when the Flux is being subscribed, that is to say when a Subscription has been produced by the Publisher and is being passed to the Subscriber.onSubscribe(Subscription).
doOnSubscribe(Consumer<? super Subscription>) - Method in class reactor.core.publisher.Mono: Add behavior (side-effect) triggered when the Mono is being subscribed, that is to say when a Subscription has been produced by the Publisher and is being passed to the Subscriber.onSubscribe(Subscription).
doOnSubscribe(Consumer<? super Subscription>) - Method in class reactor.core.publisher.ParallelFlux: Call the specified callback when a 'rail' receives a Subscription from its upstream.
doOnSubscription() - Method in class reactor.core.observability.DefaultSignalListener
doOnSubscription() - Method in interface reactor.core.observability.SignalListener: Handle the fact that the upstream Publisher acknowledged Subscription.
doOnSuccess(Consumer<? super T>) - Method in class reactor.core.publisher.Mono: Add behavior triggered as soon as the Mono can be considered to have completed successfully.
doOnTerminate(Runnable) - Method in class reactor.core.publisher.Flux: Add behavior (side-effect) triggered when the Flux terminates, either by completing successfully or failing with an error.
doOnTerminate(Runnable) - Method in class reactor.core.publisher.Mono: Add behavior triggered when the Mono terminates, either by completing with a value, completing empty or failing with an error.
doOnTerminate(Runnable) - Method in class reactor.core.publisher.ParallelFlux: Triggered when the ParallelFlux terminates, either by completing successfully or with an error.
downstreamCount() - Method in class reactor.core.publisher.DirectProcessor: Deprecated.
downstreamCount() - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.
downstreamCount() - Method in class reactor.core.publisher.FluxProcessor: Deprecated.

Return the number of active Subscriber or -1 if untracked.
downstreamCount() - Method in class reactor.core.publisher.MonoProcessor: Deprecated.

Return the number of active Subscriber or -1 if untracked.
downstreamCount() - Method in class reactor.core.publisher.ReplayProcessor: Deprecated.
downstreamCount() - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
drainSubscriber() - Static method in class reactor.core.publisher.Operators: Return a singleton Subscriber that does not check for double onSubscribe and purely request Long.MAX.
DROP - Enum constant in enum reactor.core.publisher.FluxSink.OverflowStrategy: Drop the incoming signal if the downstream is not ready to receive it.
DROP_LATEST - Enum constant in enum reactor.core.publisher.BufferOverflowStrategy: Drop the new element without propagating an error when the buffer is full.
DROP_OLDEST - Enum constant in enum reactor.core.publisher.BufferOverflowStrategy: When the buffer is full, remove the oldest element from it and offer the new element at the end instead.
duplicateOnSubscribeException() - Static method in class reactor.core.Exceptions

E

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

Map this Flux into Tuple2<Long, T> of timemillis and source data.

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

Map this Mono into Tuple2<Long, T> of timemillis and source data.

elapsed() - Method in interface reactor.core.publisher.Timed

Get the elapsed Duration since the previous onNext (or onSubscribe in case this represents the first onNext).

elapsed(Scheduler) - Method in class reactor.core.publisher.Flux

Map this Flux into Tuple2<Long, T> of timemillis and source data.

elapsed(Scheduler) - Method in class reactor.core.publisher.Mono

Map this Mono sequence into Tuple2<Long, T> of timemillis and source data.

elapsedSinceSubscription() - Method in interface reactor.core.publisher.Timed

Get the elapsed Duration since the subscription (onSubscribe signal).

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

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

Emit only the element at the given index position or IndexOutOfBoundsException if the sequence is shorter.

elementAt(int, T) - Method in class reactor.core.publisher.Flux

Emit only the element at the given index position or fall back to a default value if the sequence is shorter.

EmissionException(Throwable, Sinks.EmitResult) - Constructor for exception reactor.core.publisher.Sinks.EmissionException

EmissionException(Sinks.EmitResult) - Constructor for exception reactor.core.publisher.Sinks.EmissionException

EmissionException(Sinks.EmitResult, String) - Constructor for exception reactor.core.publisher.Sinks.EmissionException

emitComplete(Sinks.EmitFailureHandler) - Method in class reactor.core.publisher.ReplayProcessor

emitComplete(Sinks.EmitFailureHandler) - Method in interface reactor.core.publisher.Sinks.Many

A simplified attempt at completing via the Sinks.Many.tryEmitComplete() API, generating an onComplete signal.

emitEmpty(Sinks.EmitFailureHandler) - Method in class reactor.core.publisher.SinkOneSerialized

emitEmpty(Sinks.EmitFailureHandler) - Method in interface reactor.core.publisher.Sinks.Empty

A simplified attempt at completing via the Sinks.Empty.tryEmitEmpty() API, generating an onComplete signal.

emitError(Throwable, Sinks.EmitFailureHandler) - Method in class reactor.core.publisher.SinkOneSerialized

emitError(Throwable, Sinks.EmitFailureHandler) - Method in class reactor.core.publisher.ReplayProcessor

emitError(Throwable, Sinks.EmitFailureHandler) - Method in interface reactor.core.publisher.Sinks.Empty

A simplified attempt at failing the sequence via the Sinks.Empty.tryEmitError(Throwable) API, generating an onError signal.

emitError(Throwable, Sinks.EmitFailureHandler) - Method in interface reactor.core.publisher.Sinks.Many

A simplified attempt at failing the sequence via the Sinks.Many.tryEmitError(Throwable) API, generating an onError signal.

emitNext(T, Sinks.EmitFailureHandler) - Method in class reactor.core.publisher.ReplayProcessor

emitNext(T, Sinks.EmitFailureHandler) - Method in interface reactor.core.publisher.Sinks.Many

A simplified attempt at emitting a non-null element via the Sinks.Many.tryEmitNext(Object) API, generating an onNext signal.

emitNext(T, Sinks.EmitFailureHandler) - Method in class reactor.core.publisher.UnicastProcessor

Deprecated.

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

Deprecated.

To be removed in 3.5. Prefer clear cut usage of Sinks through variations of Sinks.many().multicast().onBackpressureBuffer(). If you really need the subscribe-to-upstream functionality of a Processor, switch to Sinks.ManyWithUpstream with Sinks.unsafe() variants of Sinks.unsafe().manyWithUpstream().

This processor was blocking in EmitterProcessor.onNext(Object). This behaviour can be implemented with the Sinks API by calling Sinks.Many.tryEmitNext(Object) and retrying, e.g.:

while (sink.tryEmitNext(v).hasFailed()) {
     LockSupport.parkNanos(10);
 }

emitValue(T, Sinks.EmitFailureHandler) - Method in class reactor.core.publisher.SinkOneSerialized

emitValue(T, Sinks.EmitFailureHandler) - Method in interface reactor.core.publisher.Sinks.One

A simplified attempt at emitting a non-null element via the Sinks.One.tryEmitValue(Object) API, generating an onNext signal immediately followed by an Subscriber.onComplete() signal.

empty() - Static method in class reactor.core.publisher.Flux

Create a Flux that completes without emitting any item.

empty() - Static method in class reactor.core.publisher.Mono

Create a Mono that completes without emitting any item.

empty() - Static method in class reactor.core.publisher.Sinks

A Sinks.Empty which exclusively produces one terminal signal: error or complete.

empty() - Method in interface reactor.core.publisher.Sinks.RootSpec

A Sinks.Empty which exclusively produces one terminal signal: error or complete.

empty() - Static method in class reactor.util.concurrent.Queues

A Supplier for an empty immutable Queue, to be used as a placeholder in methods that require a Queue when one doesn't expect to store any data in said Queue.

empty() - Static method in interface reactor.util.context.Context

Return an empty Context

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

A Subscriber that is expected to be used as a placeholder and never actually be called.

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

A singleton enumeration that represents a no-op Subscription instance that can be freely given out to clients.

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

Globally enables automatic context propagation to ThreadLocals.

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

Globally enables the Context loss detection in operators like

Flux.transform(java.util.function.Function<? super reactor.core.publisher.Flux<T>, ? extends org.reactivestreams.Publisher<V>>)

Mono.transformDeferred(java.util.function.Function<? super reactor.core.publisher.Mono<T>, ? extends org.reactivestreams.Publisher<V>>)

when non-Reactor types are used.

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

Deprecated.

prefer using Micrometer#timedScheduler from the reactor-core-micrometer module. To be removed at the earliest in 3.6.0.

enableOnDiscard(Context, Consumer<?>) - Static method in class reactor.core.publisher.Operators

Utility method to activate the onDiscard feature (see Flux.doOnDiscard(Class, Consumer)) in a target Context.

equals(Object) - Method in class reactor.util.function.Tuple2

equals(Object) - Method in class reactor.util.function.Tuple3

equals(Object) - Method in class reactor.util.function.Tuple4

equals(Object) - Method in class reactor.util.function.Tuple5

equals(Object) - Method in class reactor.util.function.Tuple6

equals(Object) - Method in class reactor.util.function.Tuple7

equals(Object) - Method in class reactor.util.function.Tuple8

error(String) - Method in interface reactor.util.Logger

Log a message at the ERROR level.

error(String, Object...) - Method in interface reactor.util.Logger

Log a message at the ERROR level according to the specified format and arguments.

error(String, Throwable) - Method in interface reactor.util.Logger

Log an exception (throwable) at the ERROR level with an accompanying message.

error(Throwable) - Static method in class reactor.core.publisher.Flux

Create a Flux that terminates with the specified error immediately after being subscribed to.

error(Throwable) - Method in interface reactor.core.publisher.FluxSink

Fail the sequence, generating an onError signal.

error(Throwable) - Static method in class reactor.core.publisher.Mono

Create a Mono that terminates with the specified error immediately after being subscribed to.

error(Throwable) - Method in interface reactor.core.publisher.MonoSink

Terminate with the given exception

error(Throwable) - Static method in interface reactor.core.publisher.Signal

Creates and returns a Signal of variety Type.FAILED, which holds the error.

error(Throwable) - Method in interface reactor.core.publisher.SynchronousSink

error(Throwable, boolean) - Static method in class reactor.core.publisher.Flux

Create a Flux that terminates with the specified error, either immediately after being subscribed to or after being first requested.

error(Throwable, Context) - Static method in interface reactor.core.publisher.Signal

Creates and returns a Signal of variety Type.FAILED, which holds the error and the Context associated with the erroring source.

error(Supplier<? extends Throwable>) - Static method in class reactor.core.publisher.Flux

Create a Flux that terminates with an error immediately after being subscribed to.

error(Supplier<? extends Throwable>) - Static method in class reactor.core.publisher.Mono

Create a Mono that terminates with an error immediately after being subscribed to.

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

Calls onSubscribe on the target Subscriber with the empty instance followed by a call to onError with the supplied error.

ERROR - Enum constant in enum reactor.core.publisher.BufferOverflowStrategy

Propagate an IllegalStateException when the buffer is full.

ERROR - Enum constant in enum reactor.core.publisher.FluxSink.OverflowStrategy

Signal an IllegalStateException when the downstream can't keep up

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

a Throwable attribute which indicate an error state if the scanned component keeps track of it.

errorCallbackNotImplemented(Throwable) - Static method in class reactor.core.Exceptions

Return an UnsupportedOperationException indicating that the error callback on a subscriber was not implemented, yet an error was propagated.

errorFilter - Variable in class reactor.util.retry.RetryBackoffSpec

The configured Predicate to filter which exceptions to retry.

errorFilter - Variable in class reactor.util.retry.RetrySpec

The configured Predicate to filter which exceptions to retry.

errorOrDebug(Logger.ChoiceOfMessageSupplier) - Method in interface reactor.util.Logger

Convenience method to log a message that is different according to the log level.

errorOrDebug(Logger.ChoiceOfMessageSupplier, Throwable) - Method in interface reactor.util.Logger

Convenience method to log an exception (throwable), with an accompanying message that is different according to the log level.

Exceptions - Class in reactor.core

Global Reactor Core Exception handling and utils to operate on.

Exceptions.SourceException - Exception in reactor.core

A Throwable that wraps the actual cause delivered via Subscriber.onError(Throwable) in case of Publishers that themselves emit items of type Publisher.

expand(Function<? super T, ? extends Publisher<? extends T>>) - Method in class reactor.core.publisher.Flux

Recursively expand elements into a graph and emit all the resulting element using a breadth-first traversal strategy.

expand(Function<? super T, ? extends Publisher<? extends T>>) - Method in class reactor.core.publisher.Mono

Recursively expand elements into a graph and emit all the resulting element using a breadth-first traversal strategy.

expand(Function<? super T, ? extends Publisher<? extends T>>, int) - Method in class reactor.core.publisher.Flux

Recursively expand elements into a graph and emit all the resulting element using a breadth-first traversal strategy.

expand(Function<? super T, ? extends Publisher<? extends T>>, int) - Method in class reactor.core.publisher.Mono

Recursively expand elements into a graph and emit all the resulting element using a breadth-first traversal strategy.

expandDeep(Function<? super T, ? extends Publisher<? extends T>>) - Method in class reactor.core.publisher.Flux

Recursively expand elements into a graph and emit all the resulting element, in a depth-first traversal order.

expandDeep(Function<? super T, ? extends Publisher<? extends T>>) - Method in class reactor.core.publisher.Mono

Recursively expand elements into a graph and emit all the resulting element, in a depth-first traversal order.

expandDeep(Function<? super T, ? extends Publisher<? extends T>>, int) - Method in class reactor.core.publisher.Flux

Recursively expand elements into a graph and emit all the resulting element, in a depth-first traversal order.

expandDeep(Function<? super T, ? extends Publisher<? extends T>>, int) - Method in class reactor.core.publisher.Mono

Recursively expand elements into a graph and emit all the resulting element, in a depth-first traversal order.

F

FAIL_CANCELLED - Enum constant in enum reactor.core.publisher.Sinks.EmitResult: Has failed to emit the signal because the sink was previously interrupted by its consumer
FAIL_FAST - Static variable in interface reactor.core.publisher.Sinks.EmitFailureHandler: A pre-made handler that will not instruct to retry any failure and trigger the failure handling immediately.
FAIL_NON_SERIALIZED - Enum constant in enum reactor.core.publisher.Sinks.EmitResult: Has failed to emit the signal because the access was not serialized
FAIL_OVERFLOW - Enum constant in enum reactor.core.publisher.Sinks.EmitResult: Has failed to emit the signal because the sink does not have buffering capacity left
FAIL_TERMINATED - Enum constant in enum reactor.core.publisher.Sinks.EmitResult: Has failed to emit the signal because the sink was previously terminated successfully or with an error
FAIL_ZERO_SUBSCRIBER - Enum constant in enum reactor.core.publisher.Sinks.EmitResult: Has failed to emit the signal because the sink has never been subscribed to has no capacity to buffer the signal.
failure() - Method in interface reactor.util.retry.Retry.RetrySignal: The Throwable that caused the current onError signal.
failWithCancel() - Static method in class reactor.core.Exceptions: An exception that is propagated upward and considered as "fatal" as per Reactive Stream limited list of exceptions allowed to bubble.
failWithOverflow() - Static method in class reactor.core.Exceptions: Return an IllegalStateException indicating the receiver is overrun by more signals than expected in case of a bounded queue, or more generally that data couldn't be emitted due to a lack of request
failWithOverflow(String) - Static method in class reactor.core.Exceptions: Return an IllegalStateException indicating the receiver is overrun by more signals than expected in case of a bounded queue or more generally that data couldn't be emitted due to a lack of request
failWithRejected() - Static method in class reactor.core.Exceptions: Return a singleton RejectedExecutionException
failWithRejected(String) - Static method in class reactor.core.Exceptions: Return a new RejectedExecutionException with given message.
failWithRejected(Throwable) - Static method in class reactor.core.Exceptions: Return a new RejectedExecutionException with standard message and cause, unless the cause is already a RejectedExecutionException created via Exceptions.failWithRejected(Throwable) (not the singleton-producing variants).
failWithRejectedNotTimeCapable() - Static method in class reactor.core.Exceptions: Return a singleton RejectedExecutionException with a message indicating the reason is due to the scheduler not being time-capable
FALLBACK_PROPERTY - Static variable in class reactor.util.Loggers: The system property that determines which fallback implementation to use for loggers when SLF4J isn't available.
fillInStackTrace() - Method in exception reactor.core.Exceptions.SourceException
filter(Predicate<? super Throwable>) - Method in class reactor.util.retry.RetryBackoffSpec: Set the Predicate that will filter which errors can be retried.
filter(Predicate<? super Throwable>) - Method in class reactor.util.retry.RetrySpec: Set the Predicate that will filter which errors can be retried.
filter(Predicate<? super T>) - Method in class reactor.core.publisher.Flux: Evaluate each source value against the given Predicate.
filter(Predicate<? super T>) - Method in class reactor.core.publisher.Mono: If this Mono is valued, test the result and replay it if predicate returns true.
filter(Predicate<? super T>) - Method in class reactor.core.publisher.ParallelFlux: Filters the source values on each 'rail'.
filterWhen(Function<? super T, ? extends Publisher<Boolean>>) - Method in class reactor.core.publisher.Flux: Test each value emitted by this Flux asynchronously using a generated Publisher<Boolean> test.
filterWhen(Function<? super T, ? extends Publisher<Boolean>>) - Method in class reactor.core.publisher.Mono: If this Mono is valued, test the value asynchronously using a generated Publisher<Boolean> test.
filterWhen(Function<? super T, ? extends Publisher<Boolean>>, int) - Method in class reactor.core.publisher.Flux: Test each value emitted by this Flux asynchronously using a generated Publisher<Boolean> test.
first(Iterable<? extends Publisher<? extends I>>) - Static method in class reactor.core.publisher.Flux: Deprecated.
use Flux.firstWithSignal(Iterable). To be removed in reactor 3.5.
first(Iterable<? extends Mono<? extends T>>) - Static method in class reactor.core.publisher.Mono: Deprecated.
use Mono.firstWithSignal(Iterable). To be removed in reactor 3.5.
first(Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux: Deprecated.
use Flux.firstWithSignal(Publisher[]). To be removed in reactor 3.5.
first(Mono<? extends T>...) - Static method in class reactor.core.publisher.Mono: Deprecated.
use Mono.firstWithSignal(Mono[]). To be removed in reactor 3.5.
firstWithSignal(Iterable<? extends Publisher<? extends I>>) - Static method in class reactor.core.publisher.Flux: Pick the first Publisher to emit any signal (onNext/onError/onComplete) and replay all signals from that Publisher, effectively behaving like the fastest of these competing sources.
firstWithSignal(Iterable<? extends Mono<? extends T>>) - Static method in class reactor.core.publisher.Mono: Pick the first Mono to emit any signal (value, empty completion or error) and replay that signal, effectively behaving like the fastest of these competing sources.
firstWithSignal(Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux: Pick the first Publisher to emit any signal (onNext/onError/onComplete) and replay all signals from that Publisher, effectively behaving like the fastest of these competing sources.
firstWithSignal(Mono<? extends T>...) - Static method in class reactor.core.publisher.Mono: Pick the first Mono to emit any signal (value, empty completion or error) and replay that signal, effectively behaving like the fastest of these competing sources.
firstWithValue(Iterable<? extends Publisher<? extends I>>) - Static method in class reactor.core.publisher.Flux: Pick the first Publisher to emit any value and replay all values from that Publisher, effectively behaving like the source that first emits an onNext.
firstWithValue(Iterable<? extends Mono<? extends T>>) - Static method in class reactor.core.publisher.Mono: Pick the first Mono source to emit any value and replay that signal, effectively behaving like the source that first emits an onNext.
firstWithValue(Publisher<? extends I>, Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux: Pick the first Publisher to emit any value and replay all values from that Publisher, effectively behaving like the source that first emits an onNext.
firstWithValue(Mono<? extends T>, Mono<? extends T>...) - Static method in class reactor.core.publisher.Mono: Pick the first Mono source to emit any value and replay that signal, effectively behaving like the source that first emits an onNext.
fixedDelay(long, Duration) - Static method in class reactor.util.retry.Retry: A RetryBackoffSpec preconfigured for fixed delays (min backoff equals max backoff, no jitter), given a maximum number of retry attempts and the fixed Duration for the backoff.
flatMap(Function<? super T, ? extends Publisher<? extends R>>, Function<? super Throwable, ? extends Publisher<? extends R>>, Supplier<? extends Publisher<? extends R>>) - Method in class reactor.core.publisher.Flux: Transform the signals emitted by this Flux asynchronously into Publishers, then flatten these inner publishers into a single Flux through merging, which allow them to interleave.
flatMap(Function<? super T, ? extends Publisher<? extends R>>) - Method in class reactor.core.publisher.Flux: Transform the elements emitted by this Flux asynchronously into Publishers, then flatten these inner publishers into a single Flux through merging, which allow them to interleave.
flatMap(Function<? super T, ? extends Publisher<? extends R>>) - Method in class reactor.core.publisher.ParallelFlux: Generates and flattens Publishers on each 'rail'.
flatMap(Function<? super T, ? extends Publisher<? extends R>>, boolean) - Method in class reactor.core.publisher.ParallelFlux: Generates and flattens Publishers on each 'rail', optionally delaying errors.
flatMap(Function<? super T, ? extends Publisher<? extends R>>, boolean, int) - Method in class reactor.core.publisher.ParallelFlux: Generates and flattens Publishers on each 'rail', optionally delaying errors and having a total number of simultaneous subscriptions to the inner Publishers.
flatMap(Function<? super T, ? extends Publisher<? extends R>>, boolean, int, int) - Method in class reactor.core.publisher.ParallelFlux: Generates and flattens Publishers on each 'rail', optionally delaying errors, having a total number of simultaneous subscriptions to the inner Publishers and using the given prefetch amount for the inner Publishers.
flatMap(Function<? super T, ? extends Publisher<? extends V>>, int) - Method in class reactor.core.publisher.Flux: Transform the elements emitted by this Flux asynchronously into Publishers, then flatten these inner publishers into a single Flux through merging, which allow them to interleave.
flatMap(Function<? super T, ? extends Publisher<? extends V>>, int, int) - Method in class reactor.core.publisher.Flux: Transform the elements emitted by this Flux asynchronously into Publishers, then flatten these inner publishers into a single Flux through merging, which allow them to interleave.
flatMap(Function<? super T, ? extends Mono<? extends R>>) - Method in class reactor.core.publisher.Mono: Transform the item emitted by this Mono asynchronously, returning the value emitted by another Mono (possibly changing the value type).
flatMapDelayError(Function<? super T, ? extends Publisher<? extends V>>, int, int) - Method in class reactor.core.publisher.Flux: Transform the elements emitted by this Flux asynchronously into Publishers, then flatten these inner publishers into a single Flux through merging, which allow them to interleave.
flatMapIterable(Function<? super T, ? extends Iterable<? extends R>>) - Method in class reactor.core.publisher.Flux: Transform the items emitted by this Flux into Iterable, then flatten the elements from those by merging them into a single Flux.
flatMapIterable(Function<? super T, ? extends Iterable<? extends R>>) - Method in class reactor.core.publisher.Mono: Transform the item emitted by this Mono into Iterable, then forward its elements into the returned Flux.
flatMapIterable(Function<? super T, ? extends Iterable<? extends R>>, int) - Method in class reactor.core.publisher.Flux: Transform the items emitted by this Flux into Iterable, then flatten the emissions from those by merging them into a single Flux.
flatMapMany(Function<? super T, ? extends Publisher<? extends R>>) - Method in class reactor.core.publisher.Mono: Transform the item emitted by this Mono into a Publisher, then forward its emissions into the returned Flux.
flatMapMany(Function<? super T, ? extends Publisher<? extends R>>, Function<? super Throwable, ? extends Publisher<? extends R>>, Supplier<? extends Publisher<? extends R>>) - Method in class reactor.core.publisher.Mono: Transform the signals emitted by this Mono into signal-specific Publishers, then forward the applicable Publisher's emissions into the returned Flux.
flatMapSequential(Function<? super T, ? extends Publisher<? extends R>>) - Method in class reactor.core.publisher.Flux: Transform the elements emitted by this Flux asynchronously into Publishers, then flatten these inner publishers into a single Flux, but merge them in the order of their source element.
flatMapSequential(Function<? super T, ? extends Publisher<? extends R>>, int) - Method in class reactor.core.publisher.Flux: Transform the elements emitted by this Flux asynchronously into Publishers, then flatten these inner publishers into a single Flux, but merge them in the order of their source element.
flatMapSequential(Function<? super T, ? extends Publisher<? extends R>>, int, int) - Method in class reactor.core.publisher.Flux: Transform the elements emitted by this Flux asynchronously into Publishers, then flatten these inner publishers into a single Flux, but merge them in the order of their source element.
flatMapSequentialDelayError(Function<? super T, ? extends Publisher<? extends R>>, int, int) - Method in class reactor.core.publisher.Flux: Transform the elements emitted by this Flux asynchronously into Publishers, then flatten these inner publishers into a single Flux, but merge them in the order of their source element.
flowPublisherToFlux(Flow.Publisher<T>) - Static method in class reactor.adapter.JdkFlowAdapter: Return a Flux from a java Flow.Publisher
flux() - Method in class reactor.core.publisher.Mono: Convert this Mono to a Flux
Flux<T> - Class in reactor.core.publisher: A Reactive Streams Publisher with rx operators that emits 0 to N elements, and then completes (successfully or with an error).
Flux() - Constructor for class reactor.core.publisher.Flux
FluxOperator<I,O> - Class in reactor.core.publisher: A decorating Flux Publisher that exposes Flux API over an arbitrary Publisher.
FluxOperator(Flux<? extends I>) - Constructor for class reactor.core.publisher.FluxOperator: Build a FluxOperator wrapper around the passed parent Publisher
FluxProcessor<IN,OUT> - Class in reactor.core.publisher: Deprecated.
Processors will be removed in 3.5. Prefer using Sinks.Many instead, or see https://github.com/reactor/reactor-core/issues/2431 for alternatives
FluxProcessor() - Constructor for class reactor.core.publisher.FluxProcessor: Deprecated.
FluxSink<T> - Interface in reactor.core.publisher: Wrapper API around a downstream Subscriber for emitting any number of next signals followed by zero or one onError/onComplete.
FluxSink.OverflowStrategy - Enum in reactor.core.publisher: Enumeration for backpressure handling.
fn2() - Static method in class reactor.util.function.Tuples: A converting function from Object array to Tuple2
fn3() - Static method in class reactor.util.function.Tuples: A converting function from Object array to Tuple3
fn3(Function<Tuple3<T1, T2, T3>, R>) - Static method in class reactor.util.function.Tuples: A converting function from Object array to Tuple3 to R.
fn4() - Static method in class reactor.util.function.Tuples: A converting function from Object array to Tuple4
fn4(Function<Tuple4<T1, T2, T3, T4>, R>) - Static method in class reactor.util.function.Tuples: A converting function from Object array to Tuple4 to R.
fn5() - Static method in class reactor.util.function.Tuples: A converting function from Object array to Tuple5
fn5(Function<Tuple5<T1, T2, T3, T4, T5>, R>) - Static method in class reactor.util.function.Tuples: A converting function from Object array to Tuple4 to R.
fn6() - Static method in class reactor.util.function.Tuples: A converting function from Object array to Tuple6
fn6(Function<Tuple6<T1, T2, T3, T4, T5, T6>, R>) - Static method in class reactor.util.function.Tuples: A converting function from Object array to Tuple6 to R.
fn7() - Static method in class reactor.util.function.Tuples: A converting function from Object array to Tuple7
fn7(Function<Tuple7<T1, T2, T3, T4, T5, T6, T7>, R>) - Static method in class reactor.util.function.Tuples: A converting function from Object array to Tuple7 to R.
fn8() - Static method in class reactor.util.function.Tuples: A converting function from Object array to Tuple8
fn8(Function<Tuple8<T1, T2, T3, T4, T5, T6, T7, T8>, R>) - Static method in class reactor.util.function.Tuples: A converting function from Object array to Tuple8
fnAny() - Static method in class reactor.util.function.Tuples: A converting function from Object array to Tuples
fnAny(Function<Tuple2, R>) - Static method in class reactor.util.function.Tuples: A converting function from Object array to Tuples to R.
forEach(BiConsumer<Object, Object>) - Method in interface reactor.util.context.ContextView: Perform the given action for each entry in this ContextView.
from(Object) - Static method in interface reactor.core.Scannable: Attempt to cast the Object to a Scannable.
from(Function<Flux<Retry.RetrySignal>, ? extends Publisher<?>>) - Static method in class reactor.util.retry.Retry: A wrapper around Function to provide Retry by using lambda expressions.
from(Publisher<? extends T>) - Static method in class reactor.core.publisher.Flux: Decorate the specified Publisher with the Flux API.
from(Publisher<? extends T>) - Static method in class reactor.core.publisher.Mono: Expose the specified Publisher with the Mono API, and ensure it will emit 0 or 1 item.
from(Publisher<? extends T>) - Static method in class reactor.core.publisher.ParallelFlux: Take a Publisher and prepare to consume it on multiple 'rails' (one per CPU core) in a round-robin fashion.
from(Publisher<? extends T>, int) - Static method in class reactor.core.publisher.ParallelFlux: Take a Publisher and prepare to consume it on parallelism number of 'rails', possibly ordered and in a round-robin fashion.
from(Publisher<? extends T>, int, int, Supplier<Queue<T>>) - Static method in class reactor.core.publisher.ParallelFlux: Take a Publisher and prepare to consume it on parallelism number of 'rails' and in a round-robin fashion and use custom prefetch amount and queue for dealing with the source Publisher's values.
from(Publisher<T>...) - Static method in class reactor.core.publisher.ParallelFlux: Wraps multiple Publishers into a ParallelFlux which runs them in parallel and unordered.
fromArray(Object[]) - Static method in class reactor.util.function.Tuples: Create a Tuple2 with the given array if it is small enough to fit inside a Tuple2 to Tuple8.
fromArray(T[]) - Static method in class reactor.core.publisher.Flux: Create a Flux that emits the items contained in the provided array.
fromCallable(Callable<? extends T>) - Static method in class reactor.core.publisher.Mono: Create a Mono producing its value using the provided Callable.
fromCompletionStage(CompletionStage<? extends T>) - Static method in class reactor.core.publisher.Mono: Create a Mono, producing its value using the provided CompletionStage.
fromCompletionStage(Supplier<? extends CompletionStage<? extends T>>) - Static method in class reactor.core.publisher.Mono: Create a Mono that wraps a lazily-supplied CompletionStage on subscription, emitting the value produced by the CompletionStage.
fromDirect(Publisher<? extends I>) - Static method in class reactor.core.publisher.Mono: Convert a Publisher to a Mono without any cardinality check (ie this method doesn't cancel the source past the first element).
fromExecutor(Executor) - Static method in class reactor.core.scheduler.Schedulers: Create a Scheduler which uses a backing Executor to schedule Runnables for async operators.
fromExecutor(Executor, boolean) - Static method in class reactor.core.scheduler.Schedulers: Create a Scheduler which uses a backing Executor to schedule Runnables for async operators.
fromExecutorService(ExecutorService) - Static method in class reactor.core.scheduler.Schedulers: Create a Scheduler which uses a backing ExecutorService to schedule Runnables for async operators.
fromExecutorService(ExecutorService, String) - Static method in class reactor.core.scheduler.Schedulers: Create a Scheduler which uses a backing ExecutorService to schedule Runnables for async operators.
fromFuture(CompletableFuture<? extends T>) - Static method in class reactor.core.publisher.Mono: Create a Mono, producing its value using the provided CompletableFuture and cancelling the future if the Mono gets cancelled.
fromFuture(CompletableFuture<? extends T>, boolean) - Static method in class reactor.core.publisher.Mono: Create a Mono, producing its value using the provided CompletableFuture and optionally cancelling the future if the Mono gets cancelled (if suppressCancel == false).
fromFuture(Supplier<? extends CompletableFuture<? extends T>>) - Static method in class reactor.core.publisher.Mono: Create a Mono that wraps a lazily-supplied CompletableFuture on subscription, emitting the value produced by the future and cancelling the future if the Mono gets cancelled.
fromFuture(Supplier<? extends CompletableFuture<? extends T>>, boolean) - Static method in class reactor.core.publisher.Mono: Create a Mono that wraps a lazily-supplied CompletableFuture on subscription, emitting the value produced by the future and optionally cancelling the future if the Mono gets cancelled (if suppressCancel == false).
fromIterable(Iterable<? extends T>) - Static method in class reactor.core.publisher.Flux: Create a Flux that emits the items contained in the provided Iterable.
fromRunnable(Runnable) - Static method in class reactor.core.publisher.Mono: Create a Mono that completes empty once the provided Runnable has been executed.
fromStream(Supplier<Stream<? extends T>>) - Static method in class reactor.core.publisher.Flux: Create a Flux that emits the items contained in a Stream created by the provided Supplier for each subscription.
fromStream(Stream<? extends T>) - Static method in class reactor.core.publisher.Flux: Create a Flux that emits the items contained in the provided Stream.
fromSupplier(Supplier<? extends T>) - Static method in class reactor.core.publisher.Mono: Create a Mono, producing its value using the provided Supplier.
Fuseable - Interface in reactor.core: A micro API for stream fusion, in particular marks producers that support a Fuseable.QueueSubscription.
Fuseable.ConditionalSubscriber<T> - Interface in reactor.core: A subscriber variant that can immediately tell if it consumed the value or not, directly allowing a new value to be sent if it didn't.
Fuseable.QueueSubscription<T> - Interface in reactor.core: Support contract for queue-fusion based optimizations on subscriptions.
Fuseable.ScalarCallable<T> - Interface in reactor.core: Marker interface indicating that the target can return a value or null, otherwise fail immediately and thus a viable target for assembly-time optimizations.
Fuseable.SynchronousSubscription<T> - Interface in reactor.core: Base class for synchronous sources which have fixed size and can emit their items in a pull fashion, thus avoiding the request-accounting overhead in many cases.
fusionModeName(int) - Static method in interface reactor.core.Fuseable: Attempt to convert a fusion mode int code into a human-readable representation.
fusionModeName(int, boolean) - Static method in interface reactor.core.Fuseable: Attempt to convert a fusion mode int code into a human-readable representation.

G

generate(Callable<S>, BiFunction<S, SynchronousSink<T>, S>) - Static method in class reactor.core.publisher.Flux: Programmatically create a Flux by generating signals one-by-one via a consumer callback and some state.
generate(Callable<S>, BiFunction<S, SynchronousSink<T>, S>, Consumer<? super S>) - Static method in class reactor.core.publisher.Flux: Programmatically create a Flux by generating signals one-by-one via a consumer callback and some state, with a final cleanup callback.
generate(Consumer<SynchronousSink<T>>) - Static method in class reactor.core.publisher.Flux: Programmatically create a Flux by generating signals one-by-one via a consumer callback.
generateCompanion(Flux<Long>) - Method in class reactor.util.repeat.RepeatSpec: Generates the companion publisher responsible for reacting to incoming repeat signals, effectively deciding whether to trigger another repeat cycle.
generateCompanion(Flux<Retry.RetrySignal>) - Method in class reactor.util.retry.Retry: Generates the companion publisher responsible for reacting to incoming Retry.RetrySignal emissions, effectively deciding when to retry.
generateCompanion(Flux<Retry.RetrySignal>) - Method in class reactor.util.retry.RetryBackoffSpec
generateCompanion(Flux<Retry.RetrySignal>) - Method in class reactor.util.retry.RetrySpec
get() - Method in interface reactor.core.publisher.Signal: Retrieves the item associated with this (onNext) signal.
get() - Method in interface reactor.core.publisher.Timed: Get the value wrapped by this Timed.
get(boolean) - Method in interface reactor.util.Logger.ChoiceOfMessageSupplier: Provide two possible versions of a message String, depending on the level of detail desired.
get(int) - Static method in class reactor.util.concurrent.Queues
get(int) - Method in class reactor.util.function.Tuple2: Get the object at the given index.
get(int) - Method in class reactor.util.function.Tuple3
get(int) - Method in class reactor.util.function.Tuple4
get(int) - Method in class reactor.util.function.Tuple5
get(int) - Method in class reactor.util.function.Tuple6
get(int) - Method in class reactor.util.function.Tuple7
get(int) - Method in class reactor.util.function.Tuple8
get(Class<T>) - Method in interface reactor.util.context.ContextView: Resolve a value given a type key within the Context.
get(Object) - Method in interface reactor.util.context.ContextView: Resolve a value given a key that exists within the Context, or throw a NoSuchElementException if the key is not present.
getBufferSize() - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.
getBufferSize() - Method in class reactor.core.publisher.FluxProcessor: Deprecated.

Return the processor buffer capacity if any or Integer.MAX_VALUE
getBufferSize() - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
getContextView() - Method in interface reactor.core.publisher.Signal: Return the readonly ContextView that is accessible by the time this Signal was emitted.
getError() - Method in class reactor.core.publisher.DirectProcessor: Deprecated.
getError() - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.
getError() - Method in class reactor.core.publisher.FluxProcessor: Deprecated.

Current error if any, default to null
getError() - Method in class reactor.core.publisher.MonoProcessor: Deprecated.

Return the produced Throwable error if any or null
getError() - Method in class reactor.core.publisher.ReplayProcessor: Deprecated.
getError() - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
getFusionMode() - Method in class reactor.core.observability.DefaultSignalListener: Return the fusion mode negotiated with the source: Fuseable.SYNC and Fuseable.ASYNC) as relevant if some fusion was negotiated.
getLogger(Class<?>) - Static method in class reactor.util.Loggers: Get a Logger, backed by SLF4J if present on the classpath or falling back to java.util.logging.Logger.
getLogger(String) - Static method in class reactor.util.Loggers: Get a Logger.
getName() - Method in interface reactor.util.Logger: Return the name of this Logger instance.
getOrDefault(Object, T) - Method in interface reactor.util.context.ContextView: Resolve a value given a key within the Context.
getOrEmpty(Object) - Method in interface reactor.util.context.ContextView: Resolve a value given a key within the Context.
getPending() - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.

Return the number of parked elements in the emitter backlog.
getPrefetch() - Method in class reactor.core.publisher.DirectProcessor: Deprecated.
getPrefetch() - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.
getPrefetch() - Method in class reactor.core.publisher.Flux: The prefetch configuration of the Flux
getPrefetch() - Method in class reactor.core.publisher.ParallelFlux: The prefetch configuration of the component
getPrefetch() - Method in class reactor.core.publisher.ReplayProcessor: Deprecated.
getPrefetch() - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
getReason() - Method in exception reactor.core.publisher.Sinks.EmissionException: Get the failure Sinks.EmitResult code that is represented by this exception.
getRegistry() - Static method in class reactor.util.Metrics.MicrometerConfiguration: Deprecated.
prefer using Micrometer setup in new reactor-core-micrometer module. To be removed at the earliest in 3.6.0.
getSubscription() - Method in interface reactor.core.publisher.Signal: Read the subscription associated with this (onSubscribe) signal.
getT1() - Method in class reactor.util.function.Tuple2: Type-safe way to get the first object of this Tuples.
getT2() - Method in class reactor.util.function.Tuple2: Type-safe way to get the second object of this Tuples.
getT3() - Method in class reactor.util.function.Tuple3: Type-safe way to get the third object of this Tuples.
getT4() - Method in class reactor.util.function.Tuple4: Type-safe way to get the fourth object of this Tuples.
getT5() - Method in class reactor.util.function.Tuple5: Type-safe way to get the fifth object of this Tuples.
getT6() - Method in class reactor.util.function.Tuple6: Type-safe way to get the sixth object of this Tuples.
getT7() - Method in class reactor.util.function.Tuple7: Type-safe way to get the seventh object of this Tuples.
getT8() - Method in class reactor.util.function.Tuple8: Type-safe way to get the eighth object of this Tuples.
getThrowable() - Method in interface reactor.core.publisher.Signal: Read the error associated with this (onError) signal.
getType() - Method in interface reactor.core.publisher.Signal: Read the type of this signal: SignalType.ON_SUBSCRIBE, SignalType.ON_NEXT, SignalType.ON_ERROR, or SignalType.ON_COMPLETE
groupBy(Function<? super T, ? extends K>) - Method in class reactor.core.publisher.Flux: Divide this sequence into dynamically created Flux (or groups) for each unique key, as produced by the provided keyMapper Function.
groupBy(Function<? super T, ? extends K>, int) - Method in class reactor.core.publisher.Flux: Divide this sequence into dynamically created Flux (or groups) for each unique key, as produced by the provided keyMapper Function.
groupBy(Function<? super T, ? extends K>, Function<? super T, ? extends V>) - Method in class reactor.core.publisher.Flux: Divide this sequence into dynamically created Flux (or groups) for each unique key, as produced by the provided keyMapper Function.
groupBy(Function<? super T, ? extends K>, Function<? super T, ? extends V>, int) - Method in class reactor.core.publisher.Flux: Divide this sequence into dynamically created Flux (or groups) for each unique key, as produced by the provided keyMapper Function.
GroupedFlux<K,V> - Class in reactor.core.publisher: Represents a sequence of events which has an associated key.
GroupedFlux() - Constructor for class reactor.core.publisher.GroupedFlux
groupJoin(Publisher<? extends TRight>, Function<? super T, ? extends Publisher<TLeftEnd>>, Function<? super TRight, ? extends Publisher<TRightEnd>>, BiFunction<? super T, ? super Flux<TRight>, ? extends R>) - Method in class reactor.core.publisher.Flux: Map values from two Publishers into time windows and emit combination of values in case their windows overlap.
groups() - Method in class reactor.core.publisher.ParallelFlux: Exposes the 'rails' as individual GroupedFlux instances, keyed by the rail index (zero based).

H

handle(BiConsumer<? super T, SynchronousSink<R>>) - Method in class reactor.core.publisher.Flux: Handle the items emitted by this Flux by calling a biconsumer with the output sink for each onNext.
handle(BiConsumer<? super T, SynchronousSink<R>>) - Method in class reactor.core.publisher.Mono: Handle the items emitted by this Mono by calling a biconsumer with the output sink for each onNext.
handleListenerError(Throwable) - Method in class reactor.core.observability.DefaultSignalListener
handleListenerError(Throwable) - Method in interface reactor.core.observability.SignalListener: A special handler for exceptions thrown from all the other handlers.
hasCompleted() - Method in class reactor.core.publisher.FluxProcessor: Deprecated.

Return true if terminated with onComplete
hasDownstreams() - Method in class reactor.core.publisher.DirectProcessor: Deprecated.
hasDownstreams() - Method in class reactor.core.publisher.FluxProcessor: Deprecated.

Return true if any Subscriber is actively subscribed
hasDownstreams() - Method in class reactor.core.publisher.MonoProcessor: Deprecated.

Return true if any Subscriber is actively subscribed
hasDownstreams() - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
hasElement() - Method in class reactor.core.publisher.Mono: Emit a single boolean true if this Mono has an element.
hasElement(T) - Method in class reactor.core.publisher.Flux: Emit a single boolean true if any of the elements of this Flux sequence is equal to the provided value.
hasElements() - Method in class reactor.core.publisher.Flux: Emit a single boolean true if this Flux sequence has at least one element.
hasError() - Method in class reactor.core.publisher.FluxProcessor: Deprecated.

Return true if terminated with onError
hasError() - Method in interface reactor.core.publisher.Signal: Read whether this signal is on error and carries the cause.
hashCode() - Method in class reactor.util.function.Tuple2
hashCode() - Method in class reactor.util.function.Tuple3
hashCode() - Method in class reactor.util.function.Tuple4
hashCode() - Method in class reactor.util.function.Tuple5
hashCode() - Method in class reactor.util.function.Tuple6
hashCode() - Method in class reactor.util.function.Tuple7
hashCode() - Method in class reactor.util.function.Tuple8
hasKey(Object) - Method in interface reactor.util.context.ContextView: Return true if a particular key resolves to a value within the Context.
hasValue() - Method in interface reactor.core.publisher.Signal: Has this signal an item associated with it ? (which only happens if it is an (onNext) signal)
hide() - Method in class reactor.core.publisher.ConnectableFlux
hide() - Method in class reactor.core.publisher.Flux: Hides the identities of this Flux instance.
hide() - Method in class reactor.core.publisher.Mono: Hides the identity of this Mono instance.
hide() - Method in class reactor.core.publisher.ParallelFlux: Hides the identities of this ParallelFlux and its Subscription as well.
hookFinally(SignalType) - Method in class reactor.core.publisher.BaseSubscriber: Optional hook executed after any of the termination events (onError, onComplete, cancel).
hookOnCancel() - Method in class reactor.core.publisher.BaseSubscriber: Optional hook executed when the subscription is cancelled by calling this Subscriber's BaseSubscriber.cancel() method.
hookOnComplete() - Method in class reactor.core.publisher.BaseSubscriber: Optional hook for completion processing.
hookOnError(Throwable) - Method in class reactor.core.publisher.BaseSubscriber: Optional hook for error processing.
hookOnNext(T) - Method in class reactor.core.publisher.BaseSubscriber: Hook for processing of onNext values.
hookOnSubscribe(Subscription) - Method in class reactor.core.publisher.BaseSubscriber: Hook for further processing of onSubscribe's Subscription.
Hooks - Class in reactor.core.publisher: A set of overridable lifecycle hooks that can be used for cross-cutting added behavior on Flux/Mono operators.

I

IGNORE - Enum constant in enum reactor.core.publisher.FluxSink.OverflowStrategy: Completely ignore downstream backpressure requests.
ignoreElement() - Method in class reactor.core.publisher.Mono: Ignores onNext signal (dropping it) and only propagates termination events.
ignoreElements() - Method in class reactor.core.publisher.Flux: Ignores onNext signals (dropping them) and only propagate termination events.
ignoreElements(Publisher<T>) - Static method in class reactor.core.publisher.Mono: Create a new Mono that ignores elements from the source (dropping them), but completes when the source completes.
immediate() - Static method in class reactor.core.scheduler.Schedulers: Executes tasks immediately instead of scheduling them.
Incubating - Annotation Type in reactor.util.annotation: Signifies that the annotated functionality is currently in a developmental phase.
indefinitely() - Static method in class reactor.util.retry.Retry: A RetrySpec preconfigured for the most simplistic retry strategy: retry immediately and indefinitely (similar to Flux.retry()).
index() - Method in class reactor.core.publisher.Flux: Keep information about the order in which source values were received by indexing them with a 0-based incrementing long, returning a Flux of Tuple2<(index, value)>.
index(BiFunction<? super Long, ? super T, ? extends I>) - Method in class reactor.core.publisher.Flux: Keep information about the order in which source values were received by indexing them internally with a 0-based incrementing long then combining this information with the source value into a I using the provided BiFunction, returning a Flux.
info(String) - Method in interface reactor.util.Logger: Log a message at the INFO level.
info(String, Object...) - Method in interface reactor.util.Logger: Log a message at the INFO level according to the specified format and arguments.
info(String, Throwable) - Method in interface reactor.util.Logger: Log an exception (throwable) at the INFO level with an accompanying message.
infoOrDebug(Logger.ChoiceOfMessageSupplier) - Method in interface reactor.util.Logger: Convenience method to log a message that is different according to the log level.
infoOrDebug(Logger.ChoiceOfMessageSupplier, Throwable) - Method in interface reactor.util.Logger: Convenience method to log an exception (throwable), with an accompanying message that is different according to the log level.
init() - Method in interface reactor.core.scheduler.Scheduler: Instructs this Scheduler to prepare itself for running tasks directly or through its Scheduler.Workers.
initializePublisherState(Publisher<? extends T>) - Method in interface reactor.core.observability.SignalListenerFactory: Create the STATE object for the given Publisher.
inners() - Method in class reactor.core.publisher.DirectProcessor: Deprecated.
inners() - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.
inners() - Method in class reactor.core.publisher.FluxProcessor: Deprecated.
inners() - Method in class reactor.core.publisher.MonoProcessor: Deprecated.
inners() - Method in class reactor.core.publisher.ReplayProcessor: Deprecated.
inners() - Method in class reactor.core.publisher.SinkOneSerialized
inners() - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
inners() - Method in interface reactor.core.Scannable: Return a Stream of referenced inners (flatmap, multicast etc)
interval(Duration) - Static method in class reactor.core.publisher.Flux: Create a Flux that emits long values starting with 0 and incrementing at specified time intervals on the global timer.
interval(Duration, Duration) - Static method in class reactor.core.publisher.Flux: Create a Flux that emits long values starting with 0 and incrementing at specified time intervals, after an initial delay, on the global timer.
interval(Duration, Duration, Scheduler) - Static method in class reactor.core.publisher.Flux: Create a Flux that emits long values starting with 0 and incrementing at specified time intervals, after an initial delay, on the specified Scheduler.
interval(Duration, Scheduler) - Static method in class reactor.core.publisher.Flux: Create a Flux that emits long values starting with 0 and incrementing at specified time intervals, on the specified Scheduler.
isAutomaticContextPropagationEnabled() - Static method in class reactor.core.publisher.Hooks
isBubbling(Throwable) - Static method in class reactor.core.Exceptions: Check if the given exception is a bubbled wrapped exception.
isCancel(Throwable) - Static method in class reactor.core.Exceptions: Check if the given error is a cancel signal.
isCancelled() - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.
isCancelled() - Method in interface reactor.core.publisher.FluxSink: Returns true if the downstream cancelled the sequence.
isCancelled() - Method in class reactor.core.publisher.MonoProcessor: Deprecated.
the MonoProcessor will cease to implement Subscription and this method will be removed in 3.5
isCancelled() - Method in class reactor.core.publisher.Operators.DeferredSubscription
isCancelled() - Method in class reactor.core.publisher.Operators.MonoSubscriber: Returns true if this Subscription has been cancelled.
isComplete(Object) - Static method in interface reactor.core.publisher.Signal: Check if an arbitrary Object represents a COMPLETE Signal.
isDebugEnabled() - Method in interface reactor.util.Logger: Is the logger instance enabled for the DEBUG level?
isDisposed() - Method in interface reactor.core.Disposable.Composite: Indicates if the container has already been disposed.
isDisposed() - Method in interface reactor.core.Disposable: Optionally return true when the resource or task is disposed.
isDisposed() - Method in class reactor.core.publisher.BaseSubscriber
isDisposed() - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.
isDisposed() - Method in class reactor.core.publisher.MonoProcessor: Deprecated.
isDisposed() - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
isDisposed() - Method in class reactor.core.scheduler.Schedulers.Snapshot
isEmpty() - Method in class reactor.core.publisher.Operators.MonoSubscriber
isEmpty() - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
isEmpty() - Method in interface reactor.util.context.ContextView: Return true if the Context is empty.
isError() - Method in class reactor.core.publisher.MonoProcessor: Deprecated.

Indicates whether this MonoProcessor has been completed with an error.
isError(Object) - Static method in interface reactor.core.publisher.Signal: Check if a arbitrary Object represents an ERROR Signal.
isErrorCallbackNotImplemented(Throwable) - Static method in class reactor.core.Exceptions: Check if the given error is a callback not implemented exception, in which case its cause will be the propagated error that couldn't be processed.
isErrorEnabled() - Method in interface reactor.util.Logger: Is the logger instance enabled for the ERROR level?
isFailure() - Method in enum reactor.core.publisher.Sinks.EmitResult: Represents a failure to emit a signal.
isFatal(Throwable) - Static method in class reactor.core.Exceptions: Check if a Throwable is considered by Reactor as Fatal and would be thrown by Exceptions.throwIfFatal(Throwable).
isIdentityProcessor() - Method in class reactor.core.publisher.DirectProcessor: Deprecated.
isIdentityProcessor() - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.
isIdentityProcessor() - Method in class reactor.core.publisher.FluxProcessor: Deprecated.

Return true if FluxProcessor<T, T>
isIdentityProcessor() - Method in class reactor.core.publisher.ReplayProcessor: Deprecated.
isIdentityProcessor() - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
isInfoEnabled() - Method in interface reactor.util.Logger: Is the logger instance enabled for the INFO level?
isInNonBlockingThread() - Static method in class reactor.core.scheduler.Schedulers: Check if calling a Reactor blocking API in the current Thread is forbidden or not.
isInstrumentationAvailable() - Static method in class reactor.util.Metrics: Deprecated.
prefer explicit usage of the reactor-core-micrometer module. To be removed in 3.6.0 at the earliest.
isJvmFatal(Throwable) - Static method in class reactor.core.Exceptions: Check if a Throwable is considered by Reactor as Jvm Fatal and would be thrown by both Exceptions.throwIfFatal(Throwable) and Exceptions.throwIfJvmFatal(Throwable).
isMultiple(Throwable) - Static method in class reactor.core.Exceptions: Check a Throwable to see if it is a composite, as created by Exceptions.multiple(Throwable...).
isNonBlockingThread(Thread) - Static method in class reactor.core.scheduler.Schedulers: Check if calling a Reactor blocking API in the given Thread is forbidden or not.
isOnComplete() - Method in interface reactor.core.publisher.Signal: Indicates whether this signal represents an onComplete event.
isOnError() - Method in interface reactor.core.publisher.Signal: Indicates whether this signal represents an onError event.
isOnNext() - Method in interface reactor.core.publisher.Signal: Indicates whether this signal represents an onNext event.
isOnSubscribe() - Method in interface reactor.core.publisher.Signal: Indicates whether this signal represents an onSubscribe event.
isOverflow(Throwable) - Static method in class reactor.core.Exceptions: Check if the given exception represents an overflow.
isPowerOfTwo(int) - Static method in class reactor.util.concurrent.Queues
isRetryExhausted(Throwable) - Static method in class reactor.core.Exceptions: Check a Throwable to see if it indicates too many retry attempts have failed.
isScanAvailable() - Method in interface reactor.core.Scannable: Return true whether the component is available for Scannable.scan(Attr) resolution.
isSerialized() - Method in class reactor.core.publisher.FluxProcessor: Deprecated.

Return true if this FluxProcessor supports multithread producing
isSuccess() - Method in class reactor.core.publisher.MonoProcessor: Deprecated.

Indicates whether this MonoProcessor has been successfully completed a value.
isSuccess() - Method in enum reactor.core.publisher.Sinks.EmitResult: Represents a successful emission of a signal.
isTerminated() - Method in class reactor.core.publisher.DirectProcessor: Deprecated.
isTerminated() - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.
isTerminated() - Method in class reactor.core.publisher.FluxProcessor: Deprecated.

Has this upstream finished or "completed" / "failed" ?
isTerminated() - Method in class reactor.core.publisher.MonoProcessor: Deprecated.

Indicates whether this MonoProcessor has been terminated by the source producer with a success or an error.
isTerminated() - Method in class reactor.core.publisher.ReplayProcessor: Deprecated.
isTerminated() - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
isTraceback(Throwable) - Static method in class reactor.core.Exceptions: Check a Throwable to see if it is a traceback, as created by the checkpoint operator or debug utilities.
isTraceEnabled() - Method in interface reactor.util.Logger: Is the logger instance enabled for the TRACE level?
isTransientErrors - Variable in class reactor.util.retry.RetryBackoffSpec: The configured transient error handling flag.
isTransientErrors - Variable in class reactor.util.retry.RetrySpec: The configured transient error handling flag.
isWarnEnabled() - Method in interface reactor.util.Logger: Is the logger instance enabled for the WARN level?
iteration() - Method in interface reactor.util.repeat.RepeatSpec.RepeatSignal: Returns the current iteration count, starting from 0.
iterator() - Method in interface reactor.core.Fuseable.QueueSubscription
iterator() - Method in class reactor.util.function.Tuple2: Return an immutable Iterator<Object> around the content of this Tuple.

J

JdkFlowAdapter - Class in reactor.adapter: Convert a Java 9+ Flow.Publisher to/from a Reactive Streams Publisher.
jitter(double) - Method in class reactor.util.repeat.RepeatSpec: Applies jitter to the configured fixed delay.
jitter(double) - Method in class reactor.util.retry.RetryBackoffSpec: Set a jitter factor for exponential backoffs that adds randomness to each backoff.
jitterFactor - Variable in class reactor.util.retry.RetryBackoffSpec: The configured jitter factor, as a double.
join(Publisher<? extends TRight>, Function<? super T, ? extends Publisher<TLeftEnd>>, Function<? super TRight, ? extends Publisher<TRightEnd>>, BiFunction<? super T, ? super TRight, ? extends R>) - Method in class reactor.core.publisher.Flux: Combine values from two Publishers in case their windows overlap.
just(T) - Static method in class reactor.core.publisher.Flux: Create a new Flux that will only emit a single element then onComplete.
just(T) - Static method in class reactor.core.publisher.Mono: Create a new Mono that emits the specified item, which is captured at instantiation time.
just(T...) - Static method in class reactor.core.publisher.Flux: Create a Flux that emits the provided elements and then completes.
justOrEmpty(Optional<? extends T>) - Static method in class reactor.core.publisher.Mono: Create a new Mono that emits the specified item if Optional.isPresent() otherwise only emits onComplete.
justOrEmpty(T) - Static method in class reactor.core.publisher.Mono: Create a new Mono that emits the specified item if non null otherwise only emits onComplete.

K

key() - Method in class reactor.core.publisher.GroupedFlux: Return the key of the GroupedFlux.

L

LARGE_BUFFERED - Static variable in class reactor.core.Scannable.Attr: Similar to Scannable.Attr.BUFFERED, but reserved for operators that can hold a backlog of items that can grow beyond Integer.MAX_VALUE.
last() - Method in class reactor.core.publisher.Flux: Emit the last element observed before complete signal as a Mono, or emit NoSuchElementException error if the source was empty.
last(T) - Method in class reactor.core.publisher.Flux: Emit the last element observed before complete signal as a Mono, or emit the defaultValue if the source was empty.
latest() - Method in interface reactor.core.publisher.Sinks.MulticastReplaySpec: A Sinks.Many with the following characteristics: Multicast Without Subscriber: the latest element pushed to this sink are remembered, even when there is no subscriber.
LATEST - Enum constant in enum reactor.core.publisher.FluxSink.OverflowStrategy: Downstream will get only the latest signals from upstream.
latestOrDefault(T) - Method in interface reactor.core.publisher.Sinks.MulticastReplaySpec: A Sinks.Many with the following characteristics: Multicast Without Subscriber: the latest element pushed to this sink are remembered, even when there is no subscriber. Backpressure : this sink honors downstream demand of individual subscribers. Replaying: the latest element pushed to this sink is replayed to new subscribers.
lift(BiFunction<Scannable, ? super CoreSubscriber<? super O>, ? extends CoreSubscriber<? super I>>) - Static method in class reactor.core.publisher.Operators: Create a function that can be used to support a custom operator via CoreSubscriber decoration.
lift(Predicate<Scannable>, BiFunction<Scannable, ? super CoreSubscriber<? super O>, ? extends CoreSubscriber<? super O>>) - Static method in class reactor.core.publisher.Operators: Create a function that can be used to support a custom operator via CoreSubscriber decoration.
LIFTER - Static variable in class reactor.core.Scannable.Attr: LIFTER attribute exposes name of the lifter function.
liftPublisher(BiFunction<Publisher, ? super CoreSubscriber<? super O>, ? extends CoreSubscriber<? super I>>) - Static method in class reactor.core.publisher.Operators: Create a function that can be used to support a custom operator via CoreSubscriber decoration.
liftPublisher(Predicate<Publisher>, BiFunction<Publisher, ? super CoreSubscriber<? super O>, ? extends CoreSubscriber<? super O>>) - Static method in class reactor.core.publisher.Operators: Create a function that can be used to support a custom operator via CoreSubscriber decoration.
limit(int) - Method in interface reactor.core.publisher.Sinks.MulticastReplaySpec: A Sinks.Many with the following characteristics: Multicast Without Subscriber: up to historySize elements pushed to this sink are remembered, even when there is no subscriber.
limit(int, Duration) - Method in interface reactor.core.publisher.Sinks.MulticastReplaySpec: A Sinks.Many with the following characteristics: Multicast Without Subscriber: up to historySize elements pushed to this sink are remembered, until their maxAge is reached, even when there is no subscriber.
limit(int, Duration, Scheduler) - Method in interface reactor.core.publisher.Sinks.MulticastReplaySpec: A Sinks.Many with the following characteristics: Multicast Without Subscriber: up to historySize elements pushed to this sink are remembered, until their maxAge is reached, even when there is no subscriber.
limit(Duration) - Method in interface reactor.core.publisher.Sinks.MulticastReplaySpec: A Sinks.Many with the following characteristics: Multicast Without Subscriber: all elements pushed to this sink are remembered until their maxAge is reached, even when there is no subscriber.
limit(Duration, Scheduler) - Method in interface reactor.core.publisher.Sinks.MulticastReplaySpec: A Sinks.Many with the following characteristics: Multicast Without Subscriber: all elements pushed to this sink are remembered until their maxAge is reached, even when there is no subscriber.
limitRate(int) - Method in class reactor.core.publisher.Flux: Ensure that backpressure signals from downstream subscribers are split into batches capped at the provided prefetchRate when propagated upstream, effectively rate limiting the upstream Publisher.
limitRate(int, int) - Method in class reactor.core.publisher.Flux: Ensure that backpressure signals from downstream subscribers are split into batches capped at the provided highTide first, then replenishing at the provided lowTide, effectively rate limiting the upstream Publisher.
limitRequest(long) - Method in class reactor.core.publisher.Flux: Deprecated.
replace with take(n, true) in 3.4.x, then Flux.take(long) in 3.5.0. To be removed in 3.6.0 at the earliest. See https://github.com/reactor/reactor-core/issues/2339
log() - Method in class reactor.core.publisher.Flux: Observe all Reactive Streams signals and trace them using Logger support.
log() - Method in class reactor.core.publisher.Mono: Observe all Reactive Streams signals and trace them using Logger support.
log() - Method in class reactor.core.publisher.ParallelFlux: Observe all Reactive Streams signals and use Logger support to handle trace implementation.
log(String) - Method in class reactor.core.publisher.Mono: Observe all Reactive Streams signals and use Logger support to handle trace implementation.
log(String) - Method in class reactor.core.publisher.ParallelFlux: Observe all Reactive Streams signals and use Logger support to handle trace implementation.
log(String, Level, boolean, SignalType...) - Method in class reactor.core.publisher.Flux: Observe Reactive Streams signals matching the passed filter options and trace them using Logger support.
log(String, Level, boolean, SignalType...) - Method in class reactor.core.publisher.Mono: Observe Reactive Streams signals matching the passed filter options and use Logger support to handle trace implementation.
log(String, Level, boolean, SignalType...) - Method in class reactor.core.publisher.ParallelFlux: Observe Reactive Streams signals matching the passed filter options and use Logger support to handle trace implementation.
log(String, Level, SignalType...) - Method in class reactor.core.publisher.Flux: Observe Reactive Streams signals matching the passed filter options and trace them using Logger support.
log(String, Level, SignalType...) - Method in class reactor.core.publisher.Mono: Observe Reactive Streams signals matching the passed flags options and use Logger support to handle trace implementation.
log(String, Level, SignalType...) - Method in class reactor.core.publisher.ParallelFlux: Observe Reactive Streams signals matching the passed filter options and use Logger support to handle trace implementation.
log(String) - Method in class reactor.core.publisher.Flux: Observe all Reactive Streams signals and trace them using Logger support.
log(Logger) - Method in class reactor.core.publisher.Flux: Observe Reactive Streams signals matching the passed filter options and trace them using a specific user-provided Logger, at Level.INFO level.
log(Logger) - Method in class reactor.core.publisher.Mono: Observe Reactive Streams signals matching the passed filter options and trace them using a specific user-provided Logger, at Level.INFO level.
log(Logger, Level, boolean, SignalType...) - Method in class reactor.core.publisher.Flux: Observe Reactive Streams signals matching the passed filter options and trace them using a specific user-provided Logger, at the given Level.
log(Logger, Level, boolean, SignalType...) - Method in class reactor.core.publisher.Mono: Observe Reactive Streams signals matching the passed filter options and trace them using a specific user-provided Logger, at the given Level.
Logger - Interface in reactor.util: Logger interface designed for internal Reactor usage.
Logger.ChoiceOfMessageSupplier - Interface in reactor.util: A kind of Predicate and Supplier mix, provides two variants of a message String depending on the level of detail desired.
Loggers - Class in reactor.util: Expose static methods to get a logger depending on the environment.

M

many() - Static method in class reactor.core.publisher.Sinks: Help building Sinks.Many sinks that will broadcast multiple signals to one or more Subscriber.
many() - Method in interface reactor.core.publisher.Sinks.RootSpec: Help building Sinks.Many sinks that will broadcast multiple signals to one or more Subscriber.
manyWithUpstream() - Method in interface reactor.core.publisher.Sinks.RootSpec: Help building Sinks.ManyWithUpstream sinks that can also be subscribed to an upstream Publisher.
map(Function<? super T, ? extends R>) - Method in class reactor.core.publisher.Mono: Transform the item emitted by this Mono by applying a synchronous function to it.
map(Function<? super T, ? extends U>) - Method in class reactor.core.publisher.ParallelFlux: Maps the source values on each 'rail' to another value.
map(Function<? super T, ? extends V>) - Method in class reactor.core.publisher.Flux: Transform the items emitted by this Flux by applying a synchronous function to each item.
mapNotNull(Function<? super T, ? extends R>) - Method in class reactor.core.publisher.Mono: Transform the item emitted by this Mono by applying a synchronous function to it, which is allowed to produce a null value.
mapNotNull(Function<? super T, ? extends V>) - Method in class reactor.core.publisher.Flux: Transform the items emitted by this Flux by applying a synchronous function to each item, which may produce null values.
mapT1(Function<T1, R>) - Method in class reactor.util.function.Tuple2: Map the left-hand part (T1) of this Tuple2 into a different value and type, keeping the right-hand part (T2).
mapT1(Function<T1, R>) - Method in class reactor.util.function.Tuple3: Map the 1st part (T1) of this Tuple3 into a different value and type, keeping the other parts.
mapT1(Function<T1, R>) - Method in class reactor.util.function.Tuple4: Map the 1st part (T1) of this Tuple4 into a different value and type, keeping the other parts.
mapT1(Function<T1, R>) - Method in class reactor.util.function.Tuple5: Map the 1st part (T1) of this Tuple5 into a different value and type, keeping the other parts.
mapT1(Function<T1, R>) - Method in class reactor.util.function.Tuple6: Map the 1st part (T1) of this Tuple6 into a different value and type, keeping the other parts.
mapT1(Function<T1, R>) - Method in class reactor.util.function.Tuple7: Map the 1st part (T1) of this Tuple7 into a different value and type, keeping the other parts.
mapT1(Function<T1, R>) - Method in class reactor.util.function.Tuple8: Map the 1st part (T1) of this Tuple8 into a different value and type, keeping the other parts.
mapT2(Function<T2, R>) - Method in class reactor.util.function.Tuple2: Map the right-hand part (T2) of this Tuple2 into a different value and type, keeping the left-hand part (T1).
mapT2(Function<T2, R>) - Method in class reactor.util.function.Tuple3: Map the 2nd part (T2) of this Tuple3 into a different value and type, keeping the other parts.
mapT2(Function<T2, R>) - Method in class reactor.util.function.Tuple4: Map the 2nd part (T2) of this Tuple4 into a different value and type, keeping the other parts.
mapT2(Function<T2, R>) - Method in class reactor.util.function.Tuple5: Map the 2nd part (T2) of this Tuple5 into a different value and type, keeping the other parts.
mapT2(Function<T2, R>) - Method in class reactor.util.function.Tuple6: Map the 2nd part (T2) of this Tuple6 into a different value and type, keeping the other parts.
mapT2(Function<T2, R>) - Method in class reactor.util.function.Tuple7: Map the 2nd part (T2) of this Tuple7 into a different value and type, keeping the other parts.
mapT2(Function<T2, R>) - Method in class reactor.util.function.Tuple8: Map the 2nd part (T2) of this Tuple8 into a different value and type, keeping the other parts.
mapT3(Function<T3, R>) - Method in class reactor.util.function.Tuple3: Map the 3rd part (T3) of this Tuple3 into a different value and type, keeping the other parts.
mapT3(Function<T3, R>) - Method in class reactor.util.function.Tuple4: Map the 3rd part (T3) of this Tuple4 into a different value and type, keeping the other parts.
mapT3(Function<T3, R>) - Method in class reactor.util.function.Tuple5: Map the 3rd part (T3) of this Tuple5 into a different value and type, keeping the other parts.
mapT3(Function<T3, R>) - Method in class reactor.util.function.Tuple6: Map the 3rd part (T3) of this Tuple6 into a different value and type, keeping the other parts.
mapT3(Function<T3, R>) - Method in class reactor.util.function.Tuple7: Map the 3rd part (T3) of this Tuple7 into a different value and type, keeping the other parts.
mapT3(Function<T3, R>) - Method in class reactor.util.function.Tuple8: Map the 3rd part (T3) of this Tuple8 into a different value and type, keeping the other parts.
mapT4(Function<T4, R>) - Method in class reactor.util.function.Tuple4: Map the 4th part (T4) of this Tuple4 into a different value and type, keeping the other parts.
mapT4(Function<T4, R>) - Method in class reactor.util.function.Tuple5: Map the 4th part (T4) of this Tuple5 into a different value and type, keeping the other parts.
mapT4(Function<T4, R>) - Method in class reactor.util.function.Tuple6: Map the 4th part (T4) of this Tuple6 into a different value and type, keeping the other parts.
mapT4(Function<T4, R>) - Method in class reactor.util.function.Tuple7: Map the 4th part (T4) of this Tuple7 into a different value and type, keeping the other parts.
mapT4(Function<T4, R>) - Method in class reactor.util.function.Tuple8: Map the 4th part (T4) of this Tuple8 into a different value and type, keeping the other parts.
mapT5(Function<T5, R>) - Method in class reactor.util.function.Tuple5: Map the 5th part (T5) of this Tuple5 into a different value and type, keeping the other parts.
mapT5(Function<T5, R>) - Method in class reactor.util.function.Tuple6: Map the 5th part (T5) of this Tuple6 into a different value and type, keeping the other parts.
mapT5(Function<T5, R>) - Method in class reactor.util.function.Tuple7: Map the 5th part (T5) of this Tuple7 into a different value and type, keeping the other parts.
mapT5(Function<T5, R>) - Method in class reactor.util.function.Tuple8: Map the 5th part (T5) of this Tuple8 into a different value and type, keeping the other parts.
mapT6(Function<T6, R>) - Method in class reactor.util.function.Tuple6: Map the 6th part (T6) of this Tuple6 into a different value and type, keeping the other parts.
mapT6(Function<T6, R>) - Method in class reactor.util.function.Tuple7: Map the 6th part (T6) of this Tuple7 into a different value and type, keeping the other parts.
mapT6(Function<T6, R>) - Method in class reactor.util.function.Tuple8: Map the 6th part (T6) of this Tuple8 into a different value and type, keeping the other parts.
mapT7(Function<T7, R>) - Method in class reactor.util.function.Tuple7: Map the 7th part (T7) of this Tuple7 into a different value and type, keeping the other parts.
mapT7(Function<T7, R>) - Method in class reactor.util.function.Tuple8: Map the 7th part (T7) of this Tuple8 into a different value and type, keeping the other parts.
mapT8(Function<T8, R>) - Method in class reactor.util.function.Tuple8: Map the 8th part (t8) of this Tuple8 into a different value and type, keeping the other parts.
materialize() - Method in class reactor.core.publisher.Flux: Transform incoming onNext, onError and onComplete signals into Signal instances, materializing these signals.
materialize() - Method in class reactor.core.publisher.Mono: Transform incoming onNext, onError and onComplete signals into Signal instances, materializing these signals.
max(long) - Static method in class reactor.util.retry.Retry: A RetrySpec preconfigured for a simple strategy with maximum number of retry attempts.
maxAttempts - Variable in class reactor.util.retry.RetryBackoffSpec: The configured maximum for retry attempts.
maxAttempts - Variable in class reactor.util.retry.RetrySpec: The configured maximum for retry attempts.
maxAttempts(long) - Method in class reactor.util.retry.RetryBackoffSpec: Set the maximum number of retry attempts allowed.
maxAttempts(long) - Method in class reactor.util.retry.RetrySpec: Set the maximum number of retry attempts allowed.
maxBackoff - Variable in class reactor.util.retry.RetryBackoffSpec: The configured maximum backoff Duration.
maxBackoff(Duration) - Method in class reactor.util.retry.RetryBackoffSpec: Set a hard maximum Duration for exponential backoffs.
maxInARow(long) - Static method in class reactor.util.retry.Retry: A RetrySpec preconfigured for a simple strategy with maximum number of retry attempts over subsequent transient errors.
merge(int, Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux: Merge data from Publisher sequences contained in an array / vararg into an interleaved merged sequence.
merge(Iterable<? extends Publisher<? extends I>>) - Static method in class reactor.core.publisher.Flux: Merge data from Publisher sequences contained in an Iterable into an interleaved merged sequence.
merge(Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux: Merge data from Publisher sequences contained in an array / vararg into an interleaved merged sequence.
merge(Publisher<? extends Publisher<? extends T>>) - Static method in class reactor.core.publisher.Flux: Merge data from Publisher sequences emitted by the passed Publisher into an interleaved merged sequence.
merge(Publisher<? extends Publisher<? extends T>>, int) - Static method in class reactor.core.publisher.Flux: Merge data from Publisher sequences emitted by the passed Publisher into an interleaved merged sequence.
merge(Publisher<? extends Publisher<? extends T>>, int, int) - Static method in class reactor.core.publisher.Flux: Merge data from Publisher sequences emitted by the passed Publisher into an interleaved merged sequence.
mergeComparing(int, Comparator<? super T>, Publisher<? extends T>...) - Static method in class reactor.core.publisher.Flux: Merge data from provided Publisher sequences into an ordered merged sequence, by picking the smallest values from each source (as defined by the provided Comparator).
mergeComparing(Comparator<? super T>, Publisher<? extends T>...) - Static method in class reactor.core.publisher.Flux: Merge data from provided Publisher sequences into an ordered merged sequence, by picking the smallest values from each source (as defined by the provided Comparator).
mergeComparing(Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux: Merge data from provided Publisher sequences into an ordered merged sequence, by picking the smallest values from each source (as defined by their natural order).
mergeComparingDelayError(int, Comparator<? super T>, Publisher<? extends T>...) - Static method in class reactor.core.publisher.Flux: Merge data from provided Publisher sequences into an ordered merged sequence, by picking the smallest values from each source (as defined by the provided Comparator).
mergeComparingWith(Publisher<? extends T>, Comparator<? super T>) - Method in class reactor.core.publisher.Flux: Merge data from this Flux and a Publisher into a reordered merge sequence, by picking the smallest value from each sequence as defined by a provided Comparator.
mergeDelayError(int, Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux: Merge data from Publisher sequences contained in an array / vararg into an interleaved merged sequence.
mergeOrdered(int, Comparator<? super T>, Publisher<? extends T>...) - Static method in class reactor.core.publisher.Flux: Deprecated.
Use Flux.mergeComparingDelayError(int, Comparator, Publisher[]) instead (as Flux.mergeComparing(Publisher[]) don't have this operator's delayError behavior). To be removed in 3.6.0 at the earliest.
mergeOrdered(Comparator<? super T>, Publisher<? extends T>...) - Static method in class reactor.core.publisher.Flux: Deprecated.
Use Flux.mergeComparingDelayError(int, Comparator, Publisher[]) instead (as Flux.mergeComparing(Publisher[]) don't have this operator's delayError behavior). To be removed in 3.6.0 at the earliest.
mergeOrdered(Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux: Deprecated.
Use Flux.mergeComparingDelayError(int, Comparator, Publisher[]) instead (as Flux.mergeComparing(Publisher[]) don't have this operator's delayError behavior). To be removed in 3.6.0 at the earliest.
mergeOrderedWith(Publisher<? extends T>, Comparator<? super T>) - Method in class reactor.core.publisher.Flux: Deprecated.
Use Flux.mergeComparingWith(Publisher, Comparator) instead (with the caveat that it defaults to NOT delaying errors, unlike this operator). To be removed in 3.6.0 at the earliest.
mergePriority(int, Comparator<? super T>, Publisher<? extends T>...) - Static method in class reactor.core.publisher.Flux: Merge data from provided Publisher sequences into an ordered merged sequence, by picking the smallest values from each source (as defined by the provided Comparator) as they arrive.
mergePriority(Comparator<? super T>, Publisher<? extends T>...) - Static method in class reactor.core.publisher.Flux: Merge data from provided Publisher sequences into an ordered merged sequence, by picking the smallest values from each source (as defined by the provided Comparator) as they arrive.
mergePriority(Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux: Merge data from provided Publisher sequences into an ordered merged sequence, by picking the smallest values from each source (as defined by their natural order) as they arrive.
mergePriorityDelayError(int, Comparator<? super T>, Publisher<? extends T>...) - Static method in class reactor.core.publisher.Flux: Merge data from provided Publisher sequences into an ordered merged sequence, by picking the smallest values from each source (as defined by the provided Comparator) as they arrive.
mergeSequential(int, Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux: Merge data from Publisher sequences provided in an array/vararg into an ordered merged sequence.
mergeSequential(Iterable<? extends Publisher<? extends I>>) - Static method in class reactor.core.publisher.Flux: Merge data from Publisher sequences provided in an Iterable into an ordered merged sequence.
mergeSequential(Iterable<? extends Publisher<? extends I>>, int, int) - Static method in class reactor.core.publisher.Flux: Merge data from Publisher sequences provided in an Iterable into an ordered merged sequence.
mergeSequential(Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux: Merge data from Publisher sequences provided in an array/vararg into an ordered merged sequence.
mergeSequential(Publisher<? extends Publisher<? extends T>>) - Static method in class reactor.core.publisher.Flux: Merge data from Publisher sequences emitted by the passed Publisher into an ordered merged sequence.
mergeSequential(Publisher<? extends Publisher<? extends T>>, int, int) - Static method in class reactor.core.publisher.Flux: Merge data from Publisher sequences emitted by the passed Publisher into an ordered merged sequence.
mergeSequentialDelayError(int, Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux: Merge data from Publisher sequences provided in an array/vararg into an ordered merged sequence.
mergeSequentialDelayError(Iterable<? extends Publisher<? extends I>>, int, int) - Static method in class reactor.core.publisher.Flux: Merge data from Publisher sequences provided in an Iterable into an ordered merged sequence.
mergeSequentialDelayError(Publisher<? extends Publisher<? extends T>>, int, int) - Static method in class reactor.core.publisher.Flux: Merge data from Publisher sequences emitted by the passed Publisher into an ordered merged sequence.
mergeWith(Publisher<? extends T>) - Method in class reactor.core.publisher.Flux: Merge data from this Flux and a Publisher into an interleaved merged sequence.
mergeWith(Publisher<? extends T>) - Method in class reactor.core.publisher.Mono: Merge emissions of this Mono with the provided Publisher.
metrics() - Method in class reactor.core.publisher.Flux: Deprecated.
Prefer using the Flux.tap(SignalListenerFactory) with the SignalListenerFactory provided by the new reactor-core-micrometer module. To be removed in 3.6.0 at the earliest.
metrics() - Method in class reactor.core.publisher.Mono: Deprecated.
Prefer using the Mono.tap(SignalListenerFactory) with the SignalListenerFactory provided by the new reactor-core-micrometer module. To be removed in 3.6.0 at the earliest.
Metrics - Class in reactor.util: Deprecated.
prefer using the new reactor-core-micrometer module Micrometer entrypoint. To be removed in 3.6.0 at the earliest.
Metrics() - Constructor for class reactor.util.Metrics: Deprecated.
Metrics.MicrometerConfiguration - Class in reactor.util: Deprecated.
Prefer using the reactor-core-micrometer module and configuring it using the Micrometer entrypoint.
MicrometerConfiguration() - Constructor for class reactor.util.Metrics.MicrometerConfiguration: Deprecated.
minBackoff - Variable in class reactor.util.retry.RetryBackoffSpec: The configured minimum backoff Duration.
minBackoff(Duration) - Method in class reactor.util.retry.RetryBackoffSpec: Set the minimum Duration for the first backoff.
modifyErrorFilter(Function<Predicate<Throwable>, Predicate<? super Throwable>>) - Method in class reactor.util.retry.RetryBackoffSpec: Allows to augment a previously set Predicate with a new condition to allow retries of some exception or not.
modifyErrorFilter(Function<Predicate<Throwable>, Predicate<? super Throwable>>) - Method in class reactor.util.retry.RetrySpec: Allows to augment a previously set Predicate with a new condition to allow retries of some exception or not.
Mono<T> - Class in reactor.core.publisher: A Reactive Streams Publisher with basic rx operators that emits at most one item via the onNext signal then terminates with an onComplete signal (successful Mono, with or without value), or only emits a single onError signal (failed Mono).
Mono() - Constructor for class reactor.core.publisher.Mono
MonoOperator<I,O> - Class in reactor.core.publisher: A decorating Mono Publisher that exposes Mono API over an arbitrary Publisher Useful to create operators which return a Mono.
MonoOperator(Mono<? extends I>) - Constructor for class reactor.core.publisher.MonoOperator: Build a MonoOperator wrapper around the passed parent Publisher
MonoProcessor<O> - Class in reactor.core.publisher: Deprecated.
Processors will be removed in 3.5. Prefer using Sinks.One or Sinks.Empty instead, or see https://github.com/reactor/reactor-core/issues/2431 for alternatives
MonoProcessor() - Constructor for class reactor.core.publisher.MonoProcessor: Deprecated.
MonoSink<T> - Interface in reactor.core.publisher: Wrapper API around an actual downstream Subscriber for emitting nothing, a single value or an error (mutually exclusive).
MonoSubscriber(CoreSubscriber<? super O>) - Constructor for class reactor.core.publisher.Operators.MonoSubscriber
multicast() - Method in interface reactor.core.publisher.Sinks.ManySpec: Help building Sinks.Many that will broadcast signals to multiple Subscriber
multicastOnBackpressureBuffer() - Method in interface reactor.core.publisher.Sinks.ManyWithUpstreamUnsafeSpec: A Sinks.ManyWithUpstream with the following characteristics: Multicast Without Subscriber: warm up.
multicastOnBackpressureBuffer(int, boolean) - Method in interface reactor.core.publisher.Sinks.ManyWithUpstreamUnsafeSpec: A Sinks.ManyWithUpstream with the following characteristics: Multicast Without Subscriber: warm up.
multiple(Iterable<Throwable>) - Static method in class reactor.core.Exceptions: Create a composite exception that wraps the given Throwable(s), as suppressed exceptions.
multiple(Throwable...) - Static method in class reactor.core.Exceptions: Create a composite exception that wraps the given Throwable(s), as suppressed exceptions.
multiplier - Variable in class reactor.util.retry.RetryBackoffSpec: The configured multiplier, as a double.
multiplier(double) - Method in class reactor.util.retry.RetryBackoffSpec: Set a multiplier for exponential backoffs that is used as the base for each backoff.
multiplyCap(long, long) - Static method in class reactor.core.publisher.Operators: Cap a multiplication to Long.MAX_VALUE

N

name() - Method in interface reactor.core.Scannable: Check this Scannable and its Scannable.parents() for a user-defined name and return the first one that is reachable, or default to this Scannable Scannable.stepName() if none.
name(String) - Method in class reactor.core.publisher.Flux: Give a name to this sequence, which can be retrieved using Scannable.name() as long as this is the first reachable Scannable.parents().
name(String) - Method in class reactor.core.publisher.Mono: Give a name to this sequence, which can be retrieved using Scannable.name() as long as this is the first reachable Scannable.parents().
name(String) - Method in class reactor.core.publisher.ParallelFlux: Give a name to this sequence, which can be retrieved using Scannable.name() as long as this is the first reachable Scannable.parents().
NAME - Static variable in class reactor.core.Scannable.Attr: An arbitrary name given to the operator component.
never() - Static method in class reactor.core.Disposables: Return a new Disposable that can never be disposed.
never() - Static method in class reactor.core.publisher.Flux: Create a Flux that will never signal any data, error or completion signal.
never() - Static method in class reactor.core.publisher.Mono: Return a Mono that will never signal any data, error or completion signal, essentially running indefinitely.
newBoundedElastic(int, int, String) - Static method in class reactor.core.scheduler.Schedulers: Scheduler that dynamically creates a bounded number of ExecutorService-based Workers, reusing them once the Workers have been shut down.
newBoundedElastic(int, int, String, int) - Static method in class reactor.core.scheduler.Schedulers: Scheduler that dynamically creates a bounded number of ExecutorService-based Workers, reusing them once the Workers have been shut down.
newBoundedElastic(int, int, String, int, boolean) - Static method in class reactor.core.scheduler.Schedulers: Scheduler that dynamically creates a bounded number of ExecutorService-based Workers, reusing them once the Workers have been shut down.
newBoundedElastic(int, int, ThreadFactory, int) - Method in interface reactor.core.scheduler.Schedulers.Factory: Scheduler that dynamically creates a bounded number of ExecutorService-based Workers, reusing them once the Workers have been shut down.
newBoundedElastic(int, int, ThreadFactory, int) - Static method in class reactor.core.scheduler.Schedulers: Scheduler that dynamically creates a bounded number of ExecutorService-based Workers, reusing them once the Workers have been shut down.
newParallel(int, ThreadFactory) - Method in interface reactor.core.scheduler.Schedulers.Factory: Scheduler that hosts a fixed pool of workers and is suited for parallel work.
newParallel(int, ThreadFactory) - Static method in class reactor.core.scheduler.Schedulers: Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work.
newParallel(String) - Static method in class reactor.core.scheduler.Schedulers: Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work.
newParallel(String, int) - Static method in class reactor.core.scheduler.Schedulers: Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work.
newParallel(String, int, boolean) - Static method in class reactor.core.scheduler.Schedulers: Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work.
newSingle(String) - Static method in class reactor.core.scheduler.Schedulers: Scheduler that hosts a single-threaded ExecutorService-based worker.
newSingle(String, boolean) - Static method in class reactor.core.scheduler.Schedulers: Scheduler that hosts a single-threaded ExecutorService-based worker.
newSingle(ThreadFactory) - Method in interface reactor.core.scheduler.Schedulers.Factory: Scheduler that hosts a single worker and is suited for non-blocking work.
newSingle(ThreadFactory) - Static method in class reactor.core.scheduler.Schedulers: Scheduler that hosts a single-threaded ExecutorService-based worker.
newThreadPerTaskBoundedElastic(int, int, ThreadFactory) - Method in interface reactor.core.scheduler.Schedulers.Factory: Scheduler that dynamically creates a bounded number of Workers.
next() - Method in class reactor.core.publisher.Flux: Emit only the first item emitted by this Flux, into a new Mono.
next(T) - Method in interface reactor.core.publisher.FluxSink: Emit a non-null element, generating an onNext signal.
next(T) - Static method in interface reactor.core.publisher.Signal: Creates and returns a Signal of variety Type.NEXT, which holds the value.
next(T) - Method in interface reactor.core.publisher.SynchronousSink: Try emitting, might throw an unchecked exception.
next(T, Context) - Static method in interface reactor.core.publisher.Signal: Creates and returns a Signal of variety Type.NEXT, which holds the value and the Context associated with the emitting source.
NonBlocking - Interface in reactor.core.scheduler: A marker interface that is detected on Threads while executing Reactor blocking APIs, resulting in these calls throwing an exception.
NONE - Static variable in interface reactor.core.Fuseable: Indicates the QueueSubscription can't support the requested mode.
NonNull - Annotation Type in reactor.util.annotation: Deprecated.
Use NonNull instead. To removed in 3.9.0 the earliest.
NonNullApi - Annotation Type in reactor.util.annotation: Deprecated.
Use NullMarked instead. To be removed in 3.9.0 the earliest.
NOT_SUPPORTED_MESSAGE - Static variable in interface reactor.core.Fuseable.QueueSubscription
now(TimeUnit) - Method in interface reactor.core.scheduler.Scheduler: Returns the "current time" notion of this scheduler.
Nullable - Annotation Type in reactor.util.annotation: Deprecated.
Use Nullable instead. To be removed in 3.9.0 the earliest.
nullOrNegativeRequestException(long) - Static method in class reactor.core.Exceptions

O

of(Object, Object) - Static method in interface reactor.util.context.Context: Create a Context pre-initialized with one key-value pair.
of(Object, Object, Object, Object) - Static method in interface reactor.util.context.Context: Create a Context pre-initialized with two key-value pairs.
of(Object, Object, Object, Object, Object, Object) - Static method in interface reactor.util.context.Context: Create a Context pre-initialized with three key-value pairs.
of(Object, Object, Object, Object, Object, Object, Object, Object) - Static method in interface reactor.util.context.Context: Create a Context pre-initialized with four key-value pairs.
of(Object, Object, Object, Object, Object, Object, Object, Object, Object, Object) - Static method in interface reactor.util.context.Context: Create a Context pre-initialized with five key-value pairs.
of(Map<?, ?>) - Static method in interface reactor.util.context.Context: Create a Context out of a Map.
of(ContextView) - Static method in interface reactor.util.context.Context: Create a Context out of a ContextView, enabling write API on top of the read-only view.
of(T1, T2) - Static method in class reactor.util.function.Tuples: Create a Tuple2 with the given objects.
of(T1, T2, T3) - Static method in class reactor.util.function.Tuples: Create a Tuple3 with the given objects.
of(T1, T2, T3, T4) - Static method in class reactor.util.function.Tuples: Create a Tuple4 with the given objects.
of(T1, T2, T3, T4, T5) - Static method in class reactor.util.function.Tuples: Create a Tuple5 with the given objects.
of(T1, T2, T3, T4, T5, T6) - Static method in class reactor.util.function.Tuples: Create a Tuple6 with the given objects.
of(T1, T2, T3, T4, T5, T6, T7) - Static method in class reactor.util.function.Tuples: Create a Tuple7 with the given objects.
of(T1, T2, T3, T4, T5, T6, T7, T8) - Static method in class reactor.util.function.Tuples: Create a Tuple8 with the given objects.
offer(T) - Method in interface reactor.core.Fuseable.QueueSubscription
ofType(Class) - Method in class reactor.core.publisher.Flux: Evaluate each accepted value against the given Class type.
ofType(Class) - Method in class reactor.core.publisher.Mono: Evaluate the emitted value against the given Class type.
OK - Enum constant in enum reactor.core.publisher.Sinks.EmitResult: Has successfully emitted the signal
ON_COMPLETE - Enum constant in enum reactor.core.publisher.SignalType: A signal when an operator completes
ON_CONTEXT - Enum constant in enum reactor.core.publisher.SignalType: A context update signal
ON_ERROR - Enum constant in enum reactor.core.publisher.SignalType: A signal when an operator receives an error
ON_NEXT - Enum constant in enum reactor.core.publisher.SignalType: A signal when an operator receives an emitted value
ON_SUBSCRIBE - Enum constant in enum reactor.core.publisher.SignalType: A signal when an operator receives a subscription
onAssembly(ConnectableFlux<T>) - Static method in class reactor.core.publisher.Flux: To be used by custom operators: invokes assembly Hooks pointcut given a ConnectableFlux, potentially returning a new ConnectableFlux.
onAssembly(Flux<T>) - Static method in class reactor.core.publisher.Flux: To be used by custom operators: invokes assembly Hooks pointcut given a Flux, potentially returning a new Flux.
onAssembly(Mono<T>) - Static method in class reactor.core.publisher.Mono: To be used by custom operators: invokes assembly Hooks pointcut given a Mono, potentially returning a new Mono.
onAssembly(ParallelFlux<T>) - Static method in class reactor.core.publisher.ParallelFlux: Invoke Hooks pointcut given a ParallelFlux and returning an eventually new ParallelFlux
onBackpressureBuffer() - Method in class reactor.core.publisher.Flux: Request an unbounded demand and push to the returned Flux, or park the observed elements if not enough demand is requested downstream.
onBackpressureBuffer() - Method in interface reactor.core.publisher.Sinks.MulticastSpec: A Sinks.Many with the following characteristics: Multicast Without Subscriber: warm up.
onBackpressureBuffer() - Method in interface reactor.core.publisher.Sinks.UnicastSpec: A Sinks.Many with the following characteristics: Unicast: contrary to most other Sinks.Many, the Flux view rejects subscribers past the first one. Backpressure : this sink honors downstream demand of its single Subscriber. Replaying: non-applicable, since only one Subscriber can register. Without Subscriber: all elements pushed to this sink are remembered and will be replayed once the Subscriber subscribes.
onBackpressureBuffer(int) - Method in class reactor.core.publisher.Flux: Request an unbounded demand and push to the returned Flux, or park up to maxSize elements when not enough demand is requested downstream.
onBackpressureBuffer(int) - Method in interface reactor.core.publisher.Sinks.MulticastSpec: A Sinks.Many with the following characteristics: Multicast Without Subscriber: warm up.
onBackpressureBuffer(int, boolean) - Method in interface reactor.core.publisher.Sinks.MulticastSpec: A Sinks.Many with the following characteristics: Multicast Without Subscriber: warm up.
onBackpressureBuffer(int, Consumer<? super T>) - Method in class reactor.core.publisher.Flux: Request an unbounded demand and push to the returned Flux, or park up to maxSize elements when not enough demand is requested downstream.
onBackpressureBuffer(int, Consumer<? super T>, BufferOverflowStrategy) - Method in class reactor.core.publisher.Flux: Request an unbounded demand and push to the returned Flux, or park the observed elements if not enough demand is requested downstream, within a maxSize limit.
onBackpressureBuffer(int, BufferOverflowStrategy) - Method in class reactor.core.publisher.Flux: Request an unbounded demand and push to the returned Flux, or park the observed elements if not enough demand is requested downstream, within a maxSize limit.
onBackpressureBuffer(Duration, int, Consumer<? super T>) - Method in class reactor.core.publisher.Flux: Request an unbounded demand and push to the returned Flux, or park the observed elements if not enough demand is requested downstream, within a maxSize limit and for a maximum Duration of ttl (as measured on the parallel Scheduler).
onBackpressureBuffer(Duration, int, Consumer<? super T>, Scheduler) - Method in class reactor.core.publisher.Flux: Request an unbounded demand and push to the returned Flux, or park the observed elements if not enough demand is requested downstream, within a maxSize limit and for a maximum Duration of ttl (as measured on the provided Scheduler).
onBackpressureBuffer(Queue<T>) - Method in interface reactor.core.publisher.Sinks.UnicastSpec: A Sinks.Many with the following characteristics: Unicast: contrary to most other Sinks.Many, the Flux view rejects subscribers past the first one. Backpressure : this sink honors downstream demand of its single Subscriber. Replaying: non-applicable, since only one Subscriber can register. Without Subscriber: depending on the queue, all elements pushed to this sink are remembered and will be replayed once the Subscriber subscribes.
onBackpressureBuffer(Queue<T>, Disposable) - Method in interface reactor.core.publisher.Sinks.UnicastSpec: A Sinks.Many with the following characteristics: Unicast: contrary to most other Sinks.Many, the Flux view rejects subscribers past the first one. Backpressure : this sink honors downstream demand of its single Subscriber. Replaying: non-applicable, since only one Subscriber can register. Without Subscriber: depending on the queue, all elements pushed to this sink are remembered and will be replayed once the Subscriber subscribes.
onBackpressureDrop() - Method in class reactor.core.publisher.Flux: Request an unbounded demand and push to the returned Flux, or drop the observed elements if not enough demand is requested downstream.
onBackpressureDrop(Consumer<? super T>) - Method in class reactor.core.publisher.Flux: Request an unbounded demand and push to the returned Flux, or drop and notify dropping Consumer with the observed elements if not enough demand is requested downstream.
onBackpressureError() - Method in class reactor.core.publisher.Flux: Request an unbounded demand and push to the returned Flux, or emit onError fom Exceptions.failWithOverflow() if not enough demand is requested downstream.
onBackpressureError() - Method in interface reactor.core.publisher.Sinks.UnicastSpec: A Sinks.Many with the following characteristics: Unicast: contrary to most other Sinks.Many, the Flux view rejects subscribers past the first one. Backpressure : this sink honors downstream demand of the Subscriber, and will emit Subscriber.onError(Throwable) if there is a mismatch. Replaying: No replay.
onBackpressureLatest() - Method in class reactor.core.publisher.Flux: Request an unbounded demand and push to the returned Flux, or only keep the most recent observed item if not enough demand is requested downstream.
onCancel(Disposable) - Method in interface reactor.core.publisher.FluxSink: Attach a Disposable as a callback for when this FluxSink is cancelled.
onCancel(Disposable) - Method in interface reactor.core.publisher.MonoSink: Attach a Disposable as a callback for when this MonoSink is cancelled.
once() - Static method in class reactor.util.repeat.RepeatSpec: Creates a RepeatSpec that repeats once.
onComplete() - Method in class reactor.core.publisher.BaseSubscriber
onComplete() - Method in class reactor.core.publisher.DirectProcessor: Deprecated.
onComplete() - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.
onComplete() - Method in class reactor.core.publisher.Operators.MonoSubscriber
onComplete() - Method in class reactor.core.publisher.ReplayProcessor: Deprecated.
onComplete() - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
onDiscard(T, Context) - Static method in class reactor.core.publisher.Operators: Invoke a (local or global) hook that processes elements that get discarded.
onDiscardMultiple(Collection<?>, Context) - Static method in class reactor.core.publisher.Operators: Invoke a (local or global) hook that processes elements that get discarded en masse.
onDiscardMultiple(Iterator<?>, boolean, Context) - Static method in class reactor.core.publisher.Operators: Invoke a (local or global) hook that processes elements that remains in an Iterator.
onDiscardMultiple(Spliterator<?>, boolean, Context) - Static method in class reactor.core.publisher.Operators: Invoke a (local or global) hook that processes elements that remains in an Spliterator.
onDiscardMultiple(Stream<?>, Context) - Static method in class reactor.core.publisher.Operators: Invoke a (local or global) hook that processes elements that get discarded en masse.
onDiscardQueueWithClear(Queue<T>, Context, Function<T, Stream<?>>) - Static method in class reactor.core.publisher.Operators: Invoke a (local or global) hook that processes elements that get discarded en masse after having been enqueued, due to cancellation or error.
onDispose(Disposable) - Method in interface reactor.core.publisher.FluxSink: Attach a Disposable as a callback for when this FluxSink is effectively disposed, that is it cannot be used anymore.
onDispose(Disposable) - Method in interface reactor.core.publisher.MonoSink: Attach a Disposable as a callback for when this MonoSink is effectively disposed, that is it cannot be used anymore.
one() - Static method in class reactor.core.publisher.Sinks: A Sinks.One that works like a conceptual promise: it can be completed with or without a value at any time, but only once.
one() - Method in interface reactor.core.publisher.Sinks.RootSpec: A Sinks.One that works like a conceptual promise: it can be completed with or without a value at any time, but only once.
one() - Static method in class reactor.util.concurrent.Queues
onEachOperator(String, Function<? super Publisher<Object>, ? extends Publisher<Object>>) - Static method in class reactor.core.publisher.Hooks: Add or replace a named Publisher operator interceptor for each operator created (Flux or Mono).
onEachOperator(Function<? super Publisher<Object>, ? extends Publisher<Object>>) - Static method in class reactor.core.publisher.Hooks: Add a Publisher operator interceptor for each operator created (Flux or Mono).
onEmitFailure(SignalType, Sinks.EmitResult) - Method in interface reactor.core.publisher.Sinks.EmitFailureHandler: Decide whether the emission should be retried, depending on the provided Sinks.EmitResult and the type of operation that was attempted (represented as a SignalType).
onError(Throwable) - Method in class reactor.core.publisher.BaseSubscriber
onError(Throwable) - Method in class reactor.core.publisher.DirectProcessor: Deprecated.
onError(Throwable) - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.
onError(Throwable) - Method in class reactor.core.publisher.Operators.MonoSubscriber
onError(Throwable) - Method in class reactor.core.publisher.ReplayProcessor: Deprecated.
onError(Throwable) - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
onErrorComplete() - Method in class reactor.core.publisher.Flux: Simply complete the sequence by replacing an onError signal with an onComplete signal.
onErrorComplete() - Method in class reactor.core.publisher.Mono: Simply complete the sequence by replacing an onError signal with an onComplete signal.
onErrorComplete(Class<? extends Throwable>) - Method in class reactor.core.publisher.Flux: Simply complete the sequence by replacing an onError signal with an onComplete signal if the error matches the given Class.
onErrorComplete(Class<? extends Throwable>) - Method in class reactor.core.publisher.Mono: Simply complete the sequence by replacing an onError signal with an onComplete signal if the error matches the given Class.
onErrorComplete(Predicate<? super Throwable>) - Method in class reactor.core.publisher.Flux: Simply complete the sequence by replacing an onError signal with an onComplete signal if the error matches the given Predicate.
onErrorComplete(Predicate<? super Throwable>) - Method in class reactor.core.publisher.Mono: Simply complete the sequence by replacing an onError signal with an onComplete signal if the error matches the given Predicate.
onErrorContinue(Class<E>, BiConsumer<Throwable, Object>) - Method in class reactor.core.publisher.Flux: Let compatible operators upstream recover from errors by dropping the incriminating element from the sequence and continuing with subsequent elements.
onErrorContinue(Class<E>, BiConsumer<Throwable, Object>) - Method in class reactor.core.publisher.Mono: Let compatible operators upstream recover from errors by dropping the incriminating element from the sequence and continuing with subsequent elements.
onErrorContinue(BiConsumer<Throwable, Object>) - Method in class reactor.core.publisher.Flux: Let compatible operators upstream recover from errors by dropping the incriminating element from the sequence and continuing with subsequent elements.
onErrorContinue(BiConsumer<Throwable, Object>) - Method in class reactor.core.publisher.Mono: Let compatible operators upstream recover from errors by dropping the incriminating element from the sequence and continuing with subsequent elements.
onErrorContinue(Predicate<E>, BiConsumer<Throwable, Object>) - Method in class reactor.core.publisher.Flux: Let compatible operators upstream recover from errors by dropping the incriminating element from the sequence and continuing with subsequent elements.
onErrorContinue(Predicate<E>, BiConsumer<Throwable, Object>) - Method in class reactor.core.publisher.Mono: Let compatible operators upstream recover from errors by dropping the incriminating element from the sequence and continuing with subsequent elements.
onErrorDropped(Throwable, Context) - Static method in class reactor.core.publisher.Operators: An unexpected exception is about to be dropped.
onErrorDropped(Consumer<? super Throwable>) - Static method in class reactor.core.publisher.Hooks: Override global error dropped strategy which by default bubble back the error.
onErrorMap(Class<E>, Function<? super E, ? extends Throwable>) - Method in class reactor.core.publisher.Flux: Transform an error emitted by this Flux by synchronously applying a function to it if the error matches the given type.
onErrorMap(Class<E>, Function<? super E, ? extends Throwable>) - Method in class reactor.core.publisher.Mono: Transform an error emitted by this Mono by synchronously applying a function to it if the error matches the given type.
onErrorMap(Function<? super Throwable, ? extends Throwable>) - Method in class reactor.core.publisher.Flux: Transform any error emitted by this Flux by synchronously applying a function to it.
onErrorMap(Function<? super Throwable, ? extends Throwable>) - Method in class reactor.core.publisher.Mono: Transform any error emitted by this Mono by synchronously applying a function to it.
onErrorMap(Predicate<? super Throwable>, Function<? super Throwable, ? extends Throwable>) - Method in class reactor.core.publisher.Flux: Transform an error emitted by this Flux by synchronously applying a function to it if the error matches the given predicate.
onErrorMap(Predicate<? super Throwable>, Function<? super Throwable, ? extends Throwable>) - Method in class reactor.core.publisher.Mono: Transform an error emitted by this Mono by synchronously applying a function to it if the error matches the given predicate.
onErrorResume(Class<E>, Function<? super E, ? extends Publisher<? extends T>>) - Method in class reactor.core.publisher.Flux: Subscribe to a fallback publisher when an error matching the given type occurs, using a function to choose the fallback depending on the error.
onErrorResume(Class<E>, Function<? super E, ? extends Mono<? extends T>>) - Method in class reactor.core.publisher.Mono: Subscribe to a fallback publisher when an error matching the given type occurs, using a function to choose the fallback depending on the error.
onErrorResume(Function<? super Throwable, ? extends Publisher<? extends T>>) - Method in class reactor.core.publisher.Flux: Subscribe to a returned fallback publisher when any error occurs, using a function to choose the fallback depending on the error.
onErrorResume(Function<? super Throwable, ? extends Mono<? extends T>>) - Method in class reactor.core.publisher.Mono: Subscribe to a fallback publisher when any error occurs, using a function to choose the fallback depending on the error.
onErrorResume(Predicate<? super Throwable>, Function<? super Throwable, ? extends Publisher<? extends T>>) - Method in class reactor.core.publisher.Flux: Subscribe to a fallback publisher when an error matching a given predicate occurs.
onErrorResume(Predicate<? super Throwable>, Function<? super Throwable, ? extends Mono<? extends T>>) - Method in class reactor.core.publisher.Mono: Subscribe to a fallback publisher when an error matching a given predicate occurs.
onErrorReturn(Class<E>, T) - Method in class reactor.core.publisher.Flux: Simply emit a captured fallback value when an error of the specified type is observed on this Flux.
onErrorReturn(Class<E>, T) - Method in class reactor.core.publisher.Mono: Simply emit a captured fallback value when an error of the specified type is observed on this Mono.
onErrorReturn(Predicate<? super Throwable>, T) - Method in class reactor.core.publisher.Flux: Simply emit a captured fallback value when an error matching the given predicate is observed on this Flux.
onErrorReturn(Predicate<? super Throwable>, T) - Method in class reactor.core.publisher.Mono: Simply emit a captured fallback value when an error matching the given predicate is observed on this Mono.
onErrorReturn(T) - Method in class reactor.core.publisher.Flux: Simply emit a captured fallback value when any error is observed on this Flux.
onErrorReturn(T) - Method in class reactor.core.publisher.Mono: Simply emit a captured fallback value when any error is observed on this Mono.
onErrorStop() - Method in class reactor.core.publisher.Flux: If an Flux.onErrorContinue(BiConsumer) variant has been used downstream, reverts to the default 'STOP' mode where errors are terminal events upstream.
onErrorStop() - Method in class reactor.core.publisher.Mono: If an Mono.onErrorContinue(BiConsumer) variant has been used downstream, reverts to the default 'STOP' mode where errors are terminal events upstream.
onHandleError(String, BiConsumer<Thread, ? super Throwable>) - Static method in class reactor.core.scheduler.Schedulers: Define a keyed hook part that is executed alongside other parts when a Scheduler has handled an error.
onHandleError(BiConsumer<Thread, ? super Throwable>) - Static method in class reactor.core.scheduler.Schedulers: Define a hook anonymous part that is executed alongside keyed parts when a Scheduler has handled an error.
onLastAssembly(CorePublisher<T>) - Static method in class reactor.core.publisher.Operators: Applies the hooks registered with Hooks.onLastOperator(java.util.function.Function<? super org.reactivestreams.Publisher<java.lang.Object>, ? extends org.reactivestreams.Publisher<java.lang.Object>>) and returns CorePublisher ready to be subscribed on.
onLastOperator(String, Function<? super Publisher<Object>, ? extends Publisher<Object>>) - Static method in class reactor.core.publisher.Hooks: Add or replace a named Publisher operator interceptor for the last operator created in every flow (Flux or Mono).
onLastOperator(Function<? super Publisher<Object>, ? extends Publisher<Object>>) - Static method in class reactor.core.publisher.Hooks: Add a Publisher operator interceptor for the last operator created in every flow (Flux or Mono).
onlyIf(Predicate<RepeatSpec.RepeatSignal>) - Method in class reactor.util.repeat.RepeatSpec: Sets a predicate that determines whether a repeat should occur based on the current RepeatSpec.RepeatSignal.
onNext(I) - Method in class reactor.core.publisher.Operators.MonoSubscriber
onNext(T) - Method in class reactor.core.publisher.BaseSubscriber
onNext(T) - Method in class reactor.core.publisher.DirectProcessor: Deprecated.
onNext(T) - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.
onNext(T) - Method in class reactor.core.publisher.ReplayProcessor: Deprecated.
onNext(T) - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
onNextDropped(Consumer<Object>) - Static method in class reactor.core.publisher.Hooks: Override global data dropped strategy which by default logs at DEBUG level.
onNextDropped(T, Context) - Static method in class reactor.core.publisher.Operators: An unexpected event is about to be dropped.
onNextDroppedFail() - Static method in class reactor.core.publisher.Hooks: Resets onNextDropped hook(s) and apply a strategy of throwing Exceptions.failWithCancel() instead.
onNextError(T, Throwable, Context) - Static method in class reactor.core.publisher.Operators: Find the OnNextFailureStrategy to apply to the calling async operator (which could be a local error mode defined in the Context) and apply it.
onNextError(T, Throwable, Context, Subscription) - Static method in class reactor.core.publisher.Operators: Find the OnNextFailureStrategy to apply to the calling operator (which could be a local error mode defined in the Context) and apply it.
onNextError(BiFunction<? super Throwable, Object, ? extends Throwable>) - Static method in class reactor.core.publisher.Hooks: Set the custom global error mode hook for operators that support resuming during an error in their Subscriber.onNext(Object).
onNextErrorFunction(Context) - Static method in class reactor.core.publisher.Operators
onNextInnerError(Throwable, Context, Subscription) - Static method in class reactor.core.publisher.Operators: Find the OnNextFailureStrategy to apply to the calling operator (which could be a local error mode defined in the Context) and apply it.
onNextPollError(T, Throwable, Context) - Static method in class reactor.core.publisher.Operators: Find the OnNextFailureStrategy to apply to the calling async operator (which could be a local error mode defined in the Context) and apply it.
onOperatorDebug() - Static method in class reactor.core.publisher.Hooks: Enable operator stack recorder that captures a declaration stack whenever an operator is instantiated.
onOperatorError(Subscription, Throwable, Object, Context) - Static method in class reactor.core.publisher.Operators: Map an "operator" error given an operator parent Subscription.
onOperatorError(Subscription, Throwable, Context) - Static method in class reactor.core.publisher.Operators: Map an "operator" error given an operator parent Subscription.
onOperatorError(String, BiFunction<? super Throwable, Object, ? extends Throwable>) - Static method in class reactor.core.publisher.Hooks: Add or replace a named custom error mapping, overriding the default one.
onOperatorError(Throwable, Context) - Static method in class reactor.core.publisher.Operators: Map an "operator" error.
onOperatorError(BiFunction<? super Throwable, Object, ? extends Throwable>) - Static method in class reactor.core.publisher.Hooks: Add a custom error mapping, overriding the default one.
onRejectedExecution(Throwable, Subscription, Throwable, Object, Context) - Static method in class reactor.core.publisher.Operators: Return a wrapped RejectedExecutionException which can be thrown by the operator.
onRejectedExecution(Throwable, Context) - Static method in class reactor.core.publisher.Operators: Return a wrapped RejectedExecutionException which can be thrown by the operator.
onRequest(LongConsumer) - Method in interface reactor.core.publisher.FluxSink: Attaches a LongConsumer to this FluxSink that will be notified of any request to this sink.
onRequest(LongConsumer) - Method in interface reactor.core.publisher.MonoSink: Attaches a LongConsumer to this MonoSink that will be notified of any request to this sink.
onRetryExhaustedThrow(BiFunction<RetryBackoffSpec, Retry.RetrySignal, Throwable>) - Method in class reactor.util.retry.RetryBackoffSpec: Set the generator for the Exception to be propagated when the maximum amount of retries is exhausted.
onRetryExhaustedThrow(BiFunction<RetrySpec, Retry.RetrySignal, Throwable>) - Method in class reactor.util.retry.RetrySpec: Set the generator for the Exception to be propagated when the maximum amount of retries is exhausted.
onSchedule(Runnable) - Static method in class reactor.core.scheduler.Schedulers: Applies the hooks registered with Schedulers.onScheduleHook(String, Function).
onScheduleHook(String, Function<Runnable, Runnable>) - Static method in class reactor.core.scheduler.Schedulers: Add or replace a named scheduling decorator.
onSubscribe(Subscription) - Method in interface reactor.core.CoreSubscriber: Implementors should initialize any state used by Subscriber.onNext(Object) before calling Subscription.request(long).
onSubscribe(Subscription) - Method in class reactor.core.publisher.BaseSubscriber
onSubscribe(Subscription) - Method in class reactor.core.publisher.DirectProcessor: Deprecated.
onSubscribe(Subscription) - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.
onSubscribe(Subscription) - Method in class reactor.core.publisher.Operators.MonoSubscriber
onSubscribe(Subscription) - Method in class reactor.core.publisher.ReplayProcessor: Deprecated.
onSubscribe(Subscription) - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
onTerminateDetach() - Method in class reactor.core.publisher.Flux: Detaches both the child Subscriber and the Subscription on termination or cancellation.
onTerminateDetach() - Method in class reactor.core.publisher.Mono: Detaches both the child Subscriber and the Subscription on termination or cancellation.
OPERATOR_NAME_UNRELATED_WORDS_PATTERN - Static variable in interface reactor.core.Scannable: The pattern for matching words unrelated to operator name.
Operators - Class in reactor.core.publisher: A helper to support "Operator" writing, handle noop subscriptions, validate request size and to cap concurrent additive operations to Long.MAX_VALUE, which is generic to Subscription.request(long) handling.
Operators.DeferredSubscription - Class in reactor.core.publisher: Base class for Subscribers that will receive their Subscriptions at any time, yet they might also need to be cancelled or requested at any time.
Operators.MonoSubscriber<I,O> - Class in reactor.core.publisher: A Subscriber/Subscription barrier that holds a single value at most and properly gates asynchronous behaviors resulting from concurrent request or cancel and onXXX signals.
or(Publisher<? extends T>) - Method in class reactor.core.publisher.Flux: Pick the first Publisher between this Flux and another publisher to emit any signal (onNext/onError/onComplete) and replay all signals from that Publisher, effectively behaving like the fastest of these competing sources.
or(Mono<? extends T>) - Method in class reactor.core.publisher.Mono: Emit the first available signal from this mono or the other mono.
ordered(Comparator<? super T>) - Method in class reactor.core.publisher.ParallelFlux: Merges the values from each 'rail', but choose which one to merge by way of a provided Comparator, picking the smallest of all rails.
ordered(Comparator<? super T>, int) - Method in class reactor.core.publisher.ParallelFlux: Merges the values from each 'rail', but choose which one to merge by way of a provided Comparator, picking the smallest of all rails.
orThrow() - Method in enum reactor.core.publisher.Sinks.EmitResult: Easily convert from an Sinks.EmitResult to throwing an exception on failure cases.
orThrowWithCause(Throwable) - Method in enum reactor.core.publisher.Sinks.EmitResult: Easily convert from an Sinks.EmitResult to throwing an exception on failure cases.

P

parallel() - Method in class reactor.core.publisher.Flux: Prepare this Flux by dividing data on a number of 'rails' matching the number of CPU cores, in a round-robin fashion.
parallel() - Static method in class reactor.core.scheduler.Schedulers: The common parallel instance, a Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work.
parallel(int) - Method in class reactor.core.publisher.Flux: Prepare this Flux by dividing data on a number of 'rails' matching the provided parallelism parameter, in a round-robin fashion.
parallel(int, int) - Method in class reactor.core.publisher.Flux: Prepare this Flux by dividing data on a number of 'rails' matching the provided parallelism parameter, in a round-robin fashion and using a custom prefetch amount and queue for dealing with the source Flux's values.
ParallelFlux<T> - Class in reactor.core.publisher: A ParallelFlux publishes to an array of Subscribers, in parallel 'rails' (or 'groups').
ParallelFlux() - Constructor for class reactor.core.publisher.ParallelFlux
parallelism() - Method in class reactor.core.publisher.ParallelFlux: Returns the number of expected parallel Subscribers.
PARENT - Static variable in class reactor.core.Scannable.Attr: Parent key exposes the direct upstream relationship of the scanned component.
parents() - Method in interface reactor.core.Scannable: Return a Stream navigating the Subscription chain (upward).
peek() - Method in interface reactor.core.Fuseable.QueueSubscription
peek() - Method in class reactor.core.publisher.MonoProcessor: Deprecated.
this method is discouraged, consider peeking into a MonoProcessor by turning it into a CompletableFuture
poll() - Method in class reactor.core.publisher.Operators.MonoSubscriber
poll() - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
PREFETCH - Static variable in class reactor.core.Scannable.Attr: Prefetch is an Integer attribute defining the rate of processing in a component which has capacity to request and hold a backlog of data.
produced(AtomicLongFieldUpdater<T>, T, long) - Static method in class reactor.core.publisher.Operators: Concurrent subtraction bound to 0, mostly used to decrement a request tracker by the amount produced by the operator.
propagate(Throwable) - Static method in class reactor.core.Exceptions: Prepare an unchecked RuntimeException that should be propagated downstream through Subscriber.onError(Throwable).
publish() - Method in class reactor.core.publisher.Flux: Prepare a ConnectableFlux which shares this Flux sequence and dispatches values to subscribers in a backpressure-aware manner.
publish(int) - Method in class reactor.core.publisher.Flux: Prepare a ConnectableFlux which shares this Flux sequence and dispatches values to subscribers in a backpressure-aware manner.
publish(Function<? super Flux<T>, ? extends Publisher<? extends R>>) - Method in class reactor.core.publisher.Flux: Shares a sequence for the duration of a function that may transform it and consume it as many times as necessary without causing multiple subscriptions to the upstream.
publish(Function<? super Flux<T>, ? extends Publisher<? extends R>>, int) - Method in class reactor.core.publisher.Flux: Shares a sequence for the duration of a function that may transform it and consume it as many times as necessary without causing multiple subscriptions to the upstream.
publish(Function<? super Mono<T>, ? extends Mono<? extends R>>) - Method in class reactor.core.publisher.Mono: Share a Mono for the duration of a function that may transform it and consume it as many times as necessary without causing multiple subscriptions to the upstream.
publisherToFlowPublisher(Publisher<T>) - Static method in class reactor.adapter.JdkFlowAdapter: Return a java Flow.Publisher from a Flux
publishNext() - Method in class reactor.core.publisher.Flux: Deprecated.
use Flux.shareNext() instead, or use `publish().next()` if you need to `connect(). To be removed in 3.5.0
publishOn(Scheduler) - Method in class reactor.core.publisher.Flux: Run onNext, onComplete and onError on a supplied Scheduler Worker.
publishOn(Scheduler) - Method in class reactor.core.publisher.Mono: Run onNext, onComplete and onError on a supplied Scheduler Worker.
publishOn(Scheduler, boolean, int) - Method in class reactor.core.publisher.Flux: Run onNext, onComplete and onError on a supplied Scheduler Scheduler.Worker.
publishOn(Scheduler, int) - Method in class reactor.core.publisher.Flux: Run onNext, onComplete and onError on a supplied Scheduler Scheduler.Worker.
push(Consumer<? super FluxSink<T>>) - Static method in class reactor.core.publisher.Flux: Programmatically create a Flux with the capability of emitting multiple elements from a single-threaded producer through the FluxSink API.
push(Consumer<? super FluxSink<T>>, FluxSink.OverflowStrategy) - Static method in class reactor.core.publisher.Flux: Programmatically create a Flux with the capability of emitting multiple elements from a single-threaded producer through the FluxSink API.
put(Object, Object) - Method in interface reactor.util.context.Context: Create a new Context that contains all current key/value pairs plus the given key/value pair.
putAll(Context) - Method in interface reactor.util.context.Context: Deprecated.
will be removed in 3.5, kept for backward compatibility with 3.3. Until then if you need to work around the deprecation, use Context.putAll(ContextView) combined with Context.readOnly()
putAll(ContextView) - Method in interface reactor.util.context.Context: Create a new Context by merging the content of this context and a given ContextView.
putAllMap(Map<?, ?>) - Method in interface reactor.util.context.Context: Create a new Context by merging the content of this context and a given Map.
putNonNull(Object, Object) - Method in interface reactor.util.context.Context: Create a new Context that contains all current key/value pairs plus the given key/value pair only if the value is not null.

Q

Queues - Class in reactor.util.concurrent: Queue utilities and suppliers for 1-producer/1-consumer ready queues adapted for various given capacities.

R

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.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.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.repeat - package reactor.util.repeat
reactor.util.retry - package reactor.util.retry
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
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
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.Flux: Reduce the values from this Flux sequence into a single object of the same type than the emitted items.
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.
registerNonBlockingThreadPredicate(Predicate<Thread>) - Static method in class reactor.core.scheduler.Schedulers: Registers the specified Predicate that determines whether it is forbidden to call a Reactor blocking API in a given Thread or not.
remove() - Method in interface reactor.core.Fuseable.QueueSubscription
remove(Object) - Method in interface reactor.core.Fuseable.QueueSubscription
remove(Disposable) - Method in interface reactor.core.Disposable.Composite: Delete the Disposable from this container, without disposing it.
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() - Method in class reactor.core.publisher.Mono: Repeatedly and indefinitely subscribe to the source upon completion of the previous subscription.
repeat(long) - Method in class reactor.core.publisher.Flux: Repeatedly subscribe to the source numRepeat times.
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.Flux: Repeatedly subscribe to the source if the predicate returns true after completion of the previous subscription.
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.
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(BooleanSupplier) - Method in class reactor.core.publisher.Mono: Repeatedly subscribe to the source if the predicate returns true after completion of the previous subscription.
repeatContextView() - Method in interface reactor.util.repeat.RepeatSpec.RepeatSignal: Returns the read-only context associated with this repeat signal.
RepeatSpec - Class in reactor.util.repeat: A repeat strategy that allows fine-grained control over repeating behavior in Flux.repeatWhen(java.util.function.Function<reactor.core.publisher.Flux<java.lang.Long>, ? extends org.reactivestreams.Publisher<?>>) and Mono.repeatWhen(java.util.function.Function<reactor.core.publisher.Flux<java.lang.Long>, ? extends org.reactivestreams.Publisher<?>>).
RepeatSpec.RepeatSignal - Interface in reactor.util.repeat: State information associated with each repeat signal, used in repeat strategies.
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(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.
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.
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() - 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.
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(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(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(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.
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 - Enum constant in enum reactor.core.publisher.SignalType: A signal when a request is made through the 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.
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).
resetNonBlockingThreadPredicate() - Static method in class reactor.core.scheduler.Schedulers: Unregisters all the Predicates registered so far via Schedulers.registerNonBlockingThreadPredicate(Predicate).
resetOnEachOperator() - Static method in class reactor.core.publisher.Hooks: Reset global "assembly" hook tracking
resetOnEachOperator(String) - Static method in class reactor.core.publisher.Hooks: Remove the sub-hook with key key from the onEachOperator hook.
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() - Static method in class reactor.core.publisher.Hooks: Reset global "subscriber" hook tracking
resetOnLastOperator(String) - Static method in class reactor.core.publisher.Hooks: Remove the sub-hook with key key from the onLastOperator hook.
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() - Static method in class reactor.core.publisher.Hooks: Reset global operator error mapping to the default behavior.
resetOnOperatorError(String) - Static method in class reactor.core.publisher.Hooks: Remove the sub-hook with key key from the onOperatorError hook.
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() - 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.Flux: Re-subscribes to this Flux sequence if it signals any error, for a fixed number of times.
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.

S

sample(Duration) - Method in class reactor.core.publisher.Flux: Sample this Flux by periodically emitting an item corresponding to that Flux latest emitted value within the periodical time window.
sample(Publisher) - Method in class reactor.core.publisher.Flux: Sample this Flux by emitting an item corresponding to that Flux latest emitted value whenever a companion sampler Publisher signals a value.
sampleFirst(Duration) - Method in class reactor.core.publisher.Flux: Repeatedly take a value from this Flux then skip the values that follow within a given duration.
sampleFirst(Function<? super T, ? extends Publisher>) - Method in class reactor.core.publisher.Flux: Repeatedly take a value from this Flux then skip the values that follow before the next signal from a companion sampler Publisher.
sampleTimeout(Function<? super T, ? extends Publisher>) - Method in class reactor.core.publisher.Flux: Emit the latest value from this Flux only if there were no new values emitted during the window defined by a companion Publisher derived from that particular value.
sampleTimeout(Function<? super T, ? extends Publisher>, int) - Method in class reactor.core.publisher.Flux: Emit the latest value from this Flux only if there were no new values emitted during the window defined by a companion Publisher derived from that particular value.
scalarSubscription(CoreSubscriber<? super T>, T) - Static method in class reactor.core.publisher.Operators: Represents a fuseable Subscription that emits a single constant value synchronously to a Subscriber or consumer.
scalarSubscription(CoreSubscriber<? super T>, T, String) - Static method in class reactor.core.publisher.Operators: Represents a fuseable Subscription that emits a single constant value synchronously to a Subscriber or consumer.
scan(A, BiFunction<A, ? super T, A>) - Method in class reactor.core.publisher.Flux: Reduce this Flux values with an accumulator BiFunction and also emit the intermediate results of this function.
scan(BiFunction<T, T, T>) - Method in class reactor.core.publisher.Flux: Reduce this Flux values with an accumulator BiFunction and also emit the intermediate results of this function.
scan(Scannable.Attr<T>) - Method in interface reactor.core.Scannable: Introspect a component's specific state attribute, returning an associated value specific to that component, or the default value associated with the key, or null if the attribute doesn't make sense for that particular component and has no sensible default.
Scannable - Interface in reactor.core: A Scannable component exposes state in a non strictly memory consistent way and results should be understood as best-effort hint of the underlying state.
Scannable.Attr<T> - Class in reactor.core: Base class for Scannable attributes, which all can define a meaningful default.
Scannable.Attr.RunStyle - Enum in reactor.core: An Enum enumerating the different styles an operator can run : their Enum.ordinal() reflects the level of confidence in their running mode
scanOrDefault(Scannable.Attr<T>, T) - Method in interface reactor.core.Scannable: Introspect a component's specific state attribute.
scanUnsafe(Scannable.Attr) - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.
scanUnsafe(Scannable.Attr) - Method in class reactor.core.publisher.FluxOperator
scanUnsafe(Scannable.Attr) - Method in class reactor.core.publisher.FluxProcessor: Deprecated.
scanUnsafe(Scannable.Attr) - Method in class reactor.core.publisher.MonoOperator
scanUnsafe(Scannable.Attr) - Method in class reactor.core.publisher.MonoProcessor: Deprecated.
scanUnsafe(Scannable.Attr) - Method in class reactor.core.publisher.Operators.DeferredSubscription
scanUnsafe(Scannable.Attr) - Method in class reactor.core.publisher.Operators.MonoSubscriber
scanUnsafe(Scannable.Attr) - Method in class reactor.core.publisher.ReplayProcessor: Deprecated.
scanUnsafe(Scannable.Attr) - Method in class reactor.core.publisher.SinkOneSerialized
scanUnsafe(Scannable.Attr) - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
scanUnsafe(Scannable.Attr) - Method in interface reactor.core.Scannable: This method is used internally by components to define their key-value mappings in a single place.
scanWith(Supplier<A>, BiFunction<A, ? super T, A>) - Method in class reactor.core.publisher.Flux: Reduce this Flux values with the help of an accumulator BiFunction and also emits the intermediate results.
schedule(Runnable) - Method in interface reactor.core.scheduler.Scheduler: Schedules the non-delayed execution of the given task on this scheduler.
schedule(Runnable) - Method in interface reactor.core.scheduler.Scheduler.Worker: Schedules the task for immediate execution on this worker.
schedule(Runnable, long, TimeUnit) - Method in interface reactor.core.scheduler.Scheduler: Schedules the execution of the given task with the given delay amount.
schedule(Runnable, long, TimeUnit) - Method in interface reactor.core.scheduler.Scheduler.Worker: Schedules the execution of the given task with the given delay amount.
schedulePeriodically(Runnable, long, long, TimeUnit) - Method in interface reactor.core.scheduler.Scheduler: Schedules a periodic execution of the given task with the given initial delay and period.
schedulePeriodically(Runnable, long, long, TimeUnit) - Method in interface reactor.core.scheduler.Scheduler.Worker: Schedules a periodic execution of the given task with the given initial delay and period.
scheduler(Scheduler) - Method in class reactor.util.retry.RetryBackoffSpec: Set a Scheduler on which to execute the delays computed by the exponential backoff strategy.
Scheduler - Interface in reactor.core.scheduler: Provides an abstract asynchronous boundary to operators.
Scheduler.Worker - Interface in reactor.core.scheduler: A worker representing an asynchronous boundary that executes tasks.
Schedulers - Class in reactor.core.scheduler: Schedulers provides various Scheduler flavors usable by publishOn or subscribeOn :
Schedulers() - Constructor for class reactor.core.scheduler.Schedulers
Schedulers.Factory - Interface in reactor.core.scheduler: Public factory hook to override Schedulers behavior globally
Schedulers.Snapshot - Class in reactor.core.scheduler: It is also Disposable in case you don't want to restore the live Schedulers
sequenceEqual(Publisher<? extends T>, Publisher<? extends T>) - Static method in class reactor.core.publisher.Mono: Returns a Mono that emits a Boolean value that indicates whether two Publisher sequences are the same by comparing the items emitted by each Publisher pairwise.
sequenceEqual(Publisher<? extends T>, Publisher<? extends T>, BiPredicate<? super T, ? super T>) - Static method in class reactor.core.publisher.Mono: Returns a Mono that emits a Boolean value that indicates whether two Publisher sequences are the same by comparing the items emitted by each Publisher pairwise based on the results of a specified equality function.
sequenceEqual(Publisher<? extends T>, Publisher<? extends T>, BiPredicate<? super T, ? super T>, int) - Static method in class reactor.core.publisher.Mono: Returns a Mono that emits a Boolean value that indicates whether two Publisher sequences are the same by comparing the items emitted by each Publisher pairwise based on the results of a specified equality function.
sequential() - Method in class reactor.core.publisher.ParallelFlux: Merges the values from each 'rail' in a round-robin or same-order fashion and exposes it as a regular Publisher sequence, running with a default prefetch value for the rails.
sequential(int) - Method in class reactor.core.publisher.ParallelFlux: Merges the values from each 'rail' in a round-robin or same-order fashion and exposes it as a regular Publisher sequence, running with a give prefetch value for the rails.
serialize() - Method in class reactor.core.publisher.FluxProcessor: Deprecated.

Create a FluxProcessor that safely gates multi-threaded producer Subscriber.onNext(Object).
serialize(CoreSubscriber<? super T>) - Static method in class reactor.core.publisher.Operators: Safely gate a Subscriber by making sure onNext signals are delivered sequentially (serialized).
serializeAlways() - Method in class reactor.core.publisher.FluxProcessor: Deprecated.

Returns serialization strategy.
set(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 current subscription is marked as cancelled (as in Operators.cancelledSubscription()) or was concurrently updated before.
set(Subscription) - Method in class reactor.core.publisher.Operators.DeferredSubscription: Atomically sets the single subscription and requests the missed amount from it.
setExecutorServiceDecorator(String, BiFunction<Scheduler, ScheduledExecutorService, ScheduledExecutorService>) - Static method in class reactor.core.scheduler.Schedulers: Set up an additional ScheduledExecutorService decorator for a given key, even if that key is already present.
setFactory(Schedulers.Factory) - Static method in class reactor.core.scheduler.Schedulers: Replace Schedulers factories (newParallel, newSingle and newBoundedElastic).
setFactoryWithSnapshot(Schedulers.Factory) - Static method in class reactor.core.scheduler.Schedulers: Replace Schedulers factories (newParallel, newSingle and newBoundedElastic).
setOnce(AtomicReferenceFieldUpdater<F, Subscription>, F, Subscription) - Static method in class reactor.core.publisher.Operators: Sets the given subscription once and returns true if successful, false if the field has a subscription already or has been cancelled.
setValue(O) - Method in class reactor.core.publisher.Operators.MonoSubscriber: Set the value internally, without impacting request tracking state.
share() - Method in class reactor.core.publisher.Flux: Returns a new Flux that multicasts (shares) the original Flux.
share() - Method in class reactor.core.publisher.Mono: Prepare a Mono which shares this Mono result similar to Flux.shareNext().
shareNext() - Method in class reactor.core.publisher.Flux: Prepare a Mono which shares this Flux sequence and dispatches the first observed item to subscribers.
shutdownNow() - Static method in class reactor.core.scheduler.Schedulers: Clear any cached Scheduler and call dispose on them.
Signal<T> - Interface in reactor.core.publisher: A domain representation of a Reactive Stream signal.
SignalListener<T> - Interface in reactor.core.observability: A listener which combines various handlers to be triggered per the corresponding Flux or Mono signals.
SignalListenerFactory<T,STATE> - Interface in reactor.core.observability: A factory for per-subscription SignalListener, exposing the ability to generate common state at publisher level from the source Publisher.
SignalType - Enum in reactor.core.publisher: Reactive Stream signal types
single() - Static method in class reactor.core.Disposables: Return a new simple Disposable instance that is initially not disposed but can be by calling Disposable.dispose().
single() - Method in class reactor.core.publisher.Flux: Expect and emit a single item from this Flux source or signal NoSuchElementException for an empty source, or IndexOutOfBoundsException for a source with more than one element.
single() - Method in class reactor.core.publisher.Mono: Expect exactly one item from this Mono source or signal NoSuchElementException for an empty source.
single() - Static method in class reactor.core.scheduler.Schedulers: The common single instance, a Scheduler that hosts a single-threaded ExecutorService-based worker.
single(Scheduler) - Static method in class reactor.core.scheduler.Schedulers: Wraps a single Scheduler.Worker from some other Scheduler and provides Scheduler.Worker services on top of it.
single(T) - Method in class reactor.core.publisher.Flux: Expect and emit a single item from this Flux source and emit a default value for an empty source, but signal an IndexOutOfBoundsException for a source with more than one element.
singleOptional() - Method in class reactor.core.publisher.Mono: Wrap the item produced by this Mono source into an Optional or emit an empty Optional for an empty source.
singleOrEmpty() - Method in class reactor.core.publisher.Flux: Expect and emit a single item from this Flux source, and accept an empty source but signal an IndexOutOfBoundsException for a source with more than one element.
sink() - Method in class reactor.core.publisher.FluxProcessor: Deprecated.
To be removed in 3.5, prefer clear cut usage of Sinks through the Sinks.many() spec.
sink(FluxSink.OverflowStrategy) - Method in class reactor.core.publisher.FluxProcessor: Deprecated.
To be removed in 3.5, prefer clear cut usage of Sinks through the Sinks.many() spec.
SinkOneSerialized<T> - Class in reactor.core.publisher
SinkOneSerialized(Sinks.One<T>, ContextHolder) - Constructor for class reactor.core.publisher.SinkOneSerialized
Sinks - Class in reactor.core.publisher: Sinks are constructs through which Reactive Streams signals can be programmatically pushed, with Flux or Mono semantics.
Sinks.EmissionException - Exception in reactor.core.publisher: An exception representing a failed Sinks.EmitResult.
Sinks.EmitFailureHandler - Interface in reactor.core.publisher: A handler supporting the emit API (eg.
Sinks.EmitResult - Enum in reactor.core.publisher: Represents the immediate result of an emit attempt (eg.
Sinks.Empty<T> - Interface in reactor.core.publisher: A base interface for standalone Sinks with complete-or-fail semantics.
Sinks.Many<T> - Interface in reactor.core.publisher: A base interface for standalone Sinks with Flux semantics.
Sinks.ManySpec - Interface in reactor.core.publisher: Provides Sinks.Many specs for sinks which can emit multiple elements
Sinks.ManyWithUpstream<T> - Interface in reactor.core.publisher: A Sinks.Many which additionally allows being subscribed to an upstream Publisher, which is an advanced pattern requiring external synchronization.
Sinks.ManyWithUpstreamUnsafeSpec - Interface in reactor.core.publisher: Instead of unsafe flavors of Sinks.Many, this spec provides Sinks.ManyWithUpstream implementations.
Sinks.MulticastReplaySpec - Interface in reactor.core.publisher: Provides multicast with history/replay capacity : 1 sink, N Subscriber
Sinks.MulticastSpec - Interface in reactor.core.publisher: Provides multicast : 1 sink, N Subscriber
Sinks.One<T> - Interface in reactor.core.publisher: A base interface for standalone Sinks with Mono semantics.
Sinks.RootSpec - Interface in reactor.core.publisher: Provides a choice of Sinks.One/Sinks.Empty factories and further specs for Sinks.Many.
Sinks.UnicastSpec - Interface in reactor.core.publisher: Provides unicast: 1 sink, 1 Subscriber
size() - Method in interface reactor.core.Disposable.Composite: Returns the number of currently held Disposables.
size() - Method in class reactor.core.publisher.Operators.MonoSubscriber
size() - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
size() - Method in interface reactor.util.context.ContextView: Return the size of this Context, the number of immutable key/value pairs stored inside it.
size() - Method in class reactor.util.function.Tuple2: Return the number of elements in this Tuples.
size() - Method in class reactor.util.function.Tuple3
size() - Method in class reactor.util.function.Tuple4
size() - Method in class reactor.util.function.Tuple5
size() - Method in class reactor.util.function.Tuple6
size() - Method in class reactor.util.function.Tuple7
size() - Method in class reactor.util.function.Tuple8
skip(long) - Method in class reactor.core.publisher.Flux: Skip the specified number of elements from the beginning of this Flux then emit the remaining elements.
skip(Duration) - Method in class reactor.core.publisher.Flux: Skip elements from this Flux emitted within the specified initial duration.
skip(Duration, Scheduler) - Method in class reactor.core.publisher.Flux: Skip elements from this Flux emitted within the specified initial duration, as measured on the provided Scheduler.
skipLast(int) - Method in class reactor.core.publisher.Flux: Skip a specified number of elements at the end of this Flux sequence.
skipUntil(Predicate<? super T>) - Method in class reactor.core.publisher.Flux: Skips values from this Flux until a Predicate returns true for the value.
skipUntilOther(Publisher<?>) - Method in class reactor.core.publisher.Flux: Skip values from this Flux until a specified Publisher signals an onNext or onComplete.
skipWhile(Predicate<? super T>) - Method in class reactor.core.publisher.Flux: Skips values from this Flux while a Predicate returns true for the value.
small() - Static method in class reactor.util.concurrent.Queues
SMALL_BUFFER_SIZE - Static variable in class reactor.util.concurrent.Queues: A small default of available slots in a given container, compromise between intensive pipelines, small subscribers numbers and memory use.
sort() - Method in class reactor.core.publisher.Flux: Sort elements from this Flux by collecting and sorting them in the background then emitting the sorted sequence once this sequence completes.
sort(Comparator<? super T>) - Method in class reactor.core.publisher.Flux: Sort elements from this Flux using a Comparator function, by collecting and sorting elements in the background then emitting the sorted sequence once this sequence completes.
sorted(Comparator<? super T>) - Method in class reactor.core.publisher.ParallelFlux: Sorts the 'rails' of this ParallelFlux and returns a Publisher that sequentially picks the smallest next value from the rails.
sorted(Comparator<? super T>, int) - Method in class reactor.core.publisher.ParallelFlux: Sorts the 'rails' of this ParallelFlux and returns a Publisher that sequentially picks the smallest next value from the rails.
source - Variable in class reactor.core.publisher.FluxOperator
source - Variable in class reactor.core.publisher.MonoOperator
start() - Method in interface reactor.core.scheduler.Scheduler: Deprecated.
Use Scheduler.init() instead. The use of this method is discouraged. Some implementations allowed restarting a Scheduler, while others did not. One of the issues with restarting is that checking the disposed state is unreliable in concurrent scenarios.
startWith(Iterable<? extends T>) - Method in class reactor.core.publisher.Flux: Prepend the given Iterable before this Flux sequence.
startWith(Publisher<? extends T>) - Method in class reactor.core.publisher.Flux: Prepend the given Publisher sequence to this Flux sequence.
startWith(T...) - Method in class reactor.core.publisher.Flux: Prepend the given values before this Flux sequence.
stepName() - Method in interface reactor.core.Scannable: Return a meaningful String representation of this Scannable in its chain of Scannable.parents() and Scannable.actuals().
steps() - Method in interface reactor.core.Scannable: List the step names in the chain of Scannable (including the current element), in their assembly order.
stream() - Method in interface reactor.util.context.ContextView: Stream key/value pairs from this Context
subOrZero(long, long) - Static method in class reactor.core.publisher.Operators: Cap a subtraction to 0
subscribe() - Method in class reactor.core.publisher.Flux: Subscribe to this Flux and request unbounded demand.
subscribe() - Method in class reactor.core.publisher.Mono: Subscribe to this Mono and request unbounded demand.
subscribe() - Method in class reactor.core.publisher.ParallelFlux: Subscribes to this ParallelFlux and triggers the execution chain for all 'rails'.
subscribe(Consumer<? super T>, Consumer<? super Throwable>, Runnable) - Method in class reactor.core.publisher.Flux: Subscribe Consumer to this Flux that will respectively consume all the elements in the sequence, handle errors and react to completion.
subscribe(Consumer<? super T>, Consumer<? super Throwable>, Runnable) - Method in class reactor.core.publisher.Mono: Subscribe Consumer to this Mono that will respectively consume all the elements in the sequence, handle errors and react to completion.
subscribe(Consumer<? super T>, Consumer<? super Throwable>, Runnable) - Method in class reactor.core.publisher.ParallelFlux: Subscribes to this ParallelFlux by providing an onNext, onError and onComplete callback and triggers the execution chain for all 'rails'.
subscribe(Consumer<? super T>, Consumer<? super Throwable>, Runnable, Consumer<? super Subscription>) - Method in class reactor.core.publisher.Flux: Deprecated.
Because users tend to forget to request the subsciption. If the behavior is really needed, consider using Flux.subscribeWith(Subscriber). To be removed in 3.5.
subscribe(Consumer<? super T>, Consumer<? super Throwable>, Runnable, Consumer<? super Subscription>) - Method in class reactor.core.publisher.Mono: Subscribe Consumer to this Mono that will respectively consume all the elements in the sequence, handle errors, react to completion, and request upon subscription.
subscribe(Consumer<? super T>, Consumer<? super Throwable>, Runnable, Consumer<? super Subscription>) - Method in class reactor.core.publisher.ParallelFlux: Subscribes to this ParallelFlux by providing an onNext, onError, onComplete and onSubscribe callback and triggers the execution chain for all 'rails'.
subscribe(Consumer<? super T>, Consumer<? super Throwable>, Runnable, Context) - Method in class reactor.core.publisher.Flux: Subscribe Consumer to this Flux that will respectively consume all the elements in the sequence, handle errors and react to completion.
subscribe(Consumer<? super T>, Consumer<? super Throwable>, Runnable, Context) - Method in class reactor.core.publisher.Mono: Subscribe Consumer to this Mono that will respectively consume all the elements in the sequence, handle errors and react to completion.
subscribe(Consumer<? super T>, Consumer<? super Throwable>, Runnable, Context) - Method in class reactor.core.publisher.ParallelFlux: Subscribes to this ParallelFlux by providing an onNext, onError and onComplete callback as well as an initial Context, then trigger the execution chain for all 'rails'.
subscribe(Consumer<? super T>, Consumer<? super Throwable>) - Method in class reactor.core.publisher.Flux: Subscribe to this Flux with a Consumer that will consume all the elements in the sequence, as well as a Consumer that will handle errors.
subscribe(Consumer<? super T>, Consumer<? super Throwable>) - Method in class reactor.core.publisher.Mono: Subscribe to this Mono with a Consumer that will consume all the elements in the sequence, as well as a Consumer that will handle errors.
subscribe(Consumer<? super T>, Consumer<? super Throwable>) - Method in class reactor.core.publisher.ParallelFlux: Subscribes to this ParallelFlux by providing an onNext and onError callback and triggers the execution chain for all 'rails'.
subscribe(Consumer<? super T>) - Method in class reactor.core.publisher.Flux: Subscribe a Consumer to this Flux that will consume all the elements in the sequence.
subscribe(Consumer<? super T>) - Method in class reactor.core.publisher.Mono: Subscribe a Consumer to this Mono that will consume all the sequence.
subscribe(Consumer<? super T>) - Method in class reactor.core.publisher.ParallelFlux: Subscribes to this ParallelFlux by providing an onNext callback and triggers the execution chain for all 'rails'.
subscribe(Subscriber<? super T>) - Method in class reactor.core.publisher.Flux
subscribe(Subscriber<? super T>) - Method in class reactor.core.publisher.Mono
subscribe(Subscriber<? super T>) - Method in class reactor.core.publisher.ParallelFlux: Merge the rails into a ParallelFlux.sequential() Flux and subscribe to said Flux.
subscribe(Subscription) - Static method in interface reactor.core.publisher.Signal: Creates and returns a Signal of variety Type.ON_SUBSCRIBE.
subscribe(Subscription, Context) - Static method in interface reactor.core.publisher.Signal: Creates and returns a Signal of variety Type.ON_SUBSCRIBE, that holds the Context associated with the subscribed source.
subscribe(CoreSubscriber<? super T>) - Method in interface reactor.core.CorePublisher: An internal Publisher.subscribe(Subscriber) that will bypass Hooks.onLastOperator(Function) pointcut.
subscribe(CoreSubscriber<? super T>) - Method in class reactor.core.publisher.DirectProcessor: Deprecated.
subscribe(CoreSubscriber<? super T>) - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.
subscribe(CoreSubscriber<? super T>) - Method in class reactor.core.publisher.Flux: An internal Publisher.subscribe(Subscriber) that will bypass Hooks.onLastOperator(Function) pointcut.
subscribe(CoreSubscriber<? super T>) - Method in class reactor.core.publisher.Mono: An internal Publisher.subscribe(Subscriber) that will bypass Hooks.onLastOperator(Function) pointcut.
subscribe(CoreSubscriber<? super T>) - Method in class reactor.core.publisher.ParallelFlux
subscribe(CoreSubscriber<? super T>) - Method in class reactor.core.publisher.ReplayProcessor: Deprecated.
subscribe(CoreSubscriber<? super T>) - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
subscribe(CoreSubscriber<? super T>[]) - Method in class reactor.core.publisher.ParallelFlux: Subscribes an array of Subscribers to this ParallelFlux and triggers the execution chain for all 'rails'.
SUBSCRIBE - Enum constant in enum reactor.core.publisher.SignalType: A signal when the subscription is triggered
subscribeOn(Scheduler) - Method in class reactor.core.publisher.Flux: Run subscribe, onSubscribe and request on a specified Scheduler's Scheduler.Worker.
subscribeOn(Scheduler) - Method in class reactor.core.publisher.Mono: Run subscribe, onSubscribe and request on a specified Scheduler's Scheduler.Worker.
subscribeOn(Scheduler, boolean) - Method in class reactor.core.publisher.Flux: Run subscribe and onSubscribe on a specified Scheduler's Scheduler.Worker.
subscribeTo(Publisher<? extends T>) - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.
subscribeTo(Publisher<? extends T>) - Method in interface reactor.core.publisher.Sinks.ManyWithUpstream: Explicitly subscribe this Sinks.Many to an upstream Publisher without exposing it as a Subscriber at all.
subscribeWith(E) - Method in class reactor.core.publisher.Flux: Subscribe a provided instance of a subclass of Subscriber to this Flux and return said instance for further chaining calls.
subscribeWith(E) - Method in class reactor.core.publisher.Mono: Subscribe the given Subscriber to this Mono and return said Subscriber, allowing subclasses with a richer API to be used fluently.
success() - Method in interface reactor.core.publisher.MonoSink: Complete without any value.
success(T) - Method in interface reactor.core.publisher.MonoSink: Complete this Mono with the given value.
swap() - Static method in class reactor.core.Disposables: Create a new empty Disposable.Swap with atomic guarantees on all mutative operations.
switchIfEmpty(Publisher<? extends T>) - Method in class reactor.core.publisher.Flux: Switch to an alternative Publisher if this sequence is completed without any data.
switchIfEmpty(Mono<? extends T>) - Method in class reactor.core.publisher.Mono: Fallback to an alternative Mono if this mono is completed without data
switchMap(Function<? super T, Publisher<? extends V>>) - Method in class reactor.core.publisher.Flux: Switch to a new Publisher generated via a Function whenever this Flux produces an item.
switchMap(Function<? super T, Publisher<? extends V>>, int) - Method in class reactor.core.publisher.Flux: Deprecated.
to be removed in 3.6.0 at the earliest. In 3.5.0, you should replace calls with prefetch=0 with calls to switchMap(fn), as the default behavior of the single-parameter variant will then change to prefetch=0.
switchOnFirst(BiFunction<Signal<? extends T>, Flux<T>, Publisher<? extends V>>) - Method in class reactor.core.publisher.Flux: Transform the current Flux once it emits its first element, making a conditional transformation possible.
switchOnFirst(BiFunction<Signal<? extends T>, Flux<T>, Publisher<? extends V>>, boolean) - Method in class reactor.core.publisher.Flux: Transform the current Flux once it emits its first element, making a conditional transformation possible.
switchOnNext() - Static method in class reactor.core.publisher.FluxProcessor: Deprecated.
should use Sinks, Sinks.Many.asFlux() and Flux.switchOnNext(Publisher). To be removed in 3.5.0.
switchOnNext(Publisher<? extends Publisher<? extends T>>) - Static method in class reactor.core.publisher.Flux: Creates a Flux that mirrors the most recently emitted Publisher, forwarding its data until a new Publisher comes in the source.
switchOnNext(Publisher<? extends Publisher<? extends T>>, int) - Static method in class reactor.core.publisher.Flux: Deprecated.
to be removed in 3.6.0 at the earliest. In 3.5.0, you should replace calls with prefetch=0 with calls to switchOnNext(mergedPublishers), as the default behavior of the single-parameter variant will then change to prefetch=0.
SYNC - Enum constant in enum reactor.core.Scannable.Attr.RunStyle: guarantees the operator doesn't change threads (strongest level of guarantee)
SYNC - Static variable in interface reactor.core.Fuseable: Indicates the QueueSubscription can perform sync-fusion.
SynchronousSink<T> - Interface in reactor.core.publisher: Interface to produce synchronously "one signal" to an underlying Subscriber.

T

tag(String, String) - Method in class reactor.core.publisher.Flux: Tag this flux with a key/value pair.
tag(String, String) - Method in class reactor.core.publisher.Mono: Tag this mono with a key/value pair.
tag(String, String) - Method in class reactor.core.publisher.ParallelFlux: Tag this ParallelFlux with a key/value pair.
tags() - Method in interface reactor.core.Scannable: Visit this Scannable and its Scannable.parents(), starting by the furthest reachable parent, and return a Stream of the tags which includes duplicates and outputs tags in declaration order (grandparent tag(s) > parent tag(s) > current tag(s)).
TAGS - Static variable in class reactor.core.Scannable.Attr: A Stream of Tuple2 representing key/value pairs for tagged components.
tagsDeduplicated() - Method in interface reactor.core.Scannable: Deprecated.
Micrometer APIs generally deduplicate tags and key-value pairs by default, so for related use cases prefer Scannable.tags().
take(long) - Method in class reactor.core.publisher.Flux: Take only the first N values from this Flux, if available.
take(long, boolean) - Method in class reactor.core.publisher.Flux: Take only the first N values from this Flux, if available.
take(Duration) - Method in class reactor.core.publisher.Flux: Relay values from this Flux until the specified Duration elapses.
take(Duration) - Method in class reactor.core.publisher.Mono: Give this Mono a chance to resolve within a specified time frame but complete if it doesn't.
take(Duration, Scheduler) - Method in class reactor.core.publisher.Flux: Relay values from this Flux until the specified Duration elapses, as measured on the specified Scheduler.
take(Duration, Scheduler) - Method in class reactor.core.publisher.Mono: Give this Mono a chance to resolve within a specified time frame but complete if it doesn't.
takeLast(int) - Method in class reactor.core.publisher.Flux: Emit the last N values this Flux emitted before its completion.
takeUntil(Predicate<? super T>) - Method in class reactor.core.publisher.Flux: Relay values from this Flux until the given Predicate matches.
takeUntilOther(Publisher<?>) - Method in class reactor.core.publisher.Flux: Relay values from this Flux until the given Publisher emits.
takeUntilOther(Publisher<?>) - Method in class reactor.core.publisher.Mono: Give this Mono a chance to resolve before a companion Publisher emits.
takeWhile(Predicate<? super T>) - Method in class reactor.core.publisher.Flux: Relay values from this Flux while a predicate returns TRUE for the values (checked before each value is delivered).
tap(Function<ContextView, SignalListener<T>>) - Method in class reactor.core.publisher.Flux: Tap into Reactive Streams signals emitted or received by this Flux and notify a stateful per-Subscriber SignalListener.
tap(Function<ContextView, SignalListener<T>>) - Method in class reactor.core.publisher.Mono: Tap into Reactive Streams signals emitted or received by this Mono and notify a stateful per-Subscriber SignalListener.
tap(Supplier<SignalListener<T>>) - Method in class reactor.core.publisher.Flux: Tap into Reactive Streams signals emitted or received by this Flux and notify a stateful per-Subscriber SignalListener.
tap(Supplier<SignalListener<T>>) - Method in class reactor.core.publisher.Mono: Tap into Reactive Streams signals emitted or received by this Mono and notify a stateful per-Subscriber SignalListener.
tap(SignalListenerFactory<T, ?>) - Method in class reactor.core.publisher.Flux: Tap into Reactive Streams signals emitted or received by this Flux and notify a stateful per-Subscriber SignalListener created by the provided SignalListenerFactory.
tap(SignalListenerFactory<T, ?>) - Method in class reactor.core.publisher.Mono: Tap into Reactive Streams signals emitted or received by this Mono and notify a stateful per-Subscriber SignalListener created by the provided SignalListenerFactory.
terminate() - Method in class reactor.core.publisher.Operators.DeferredSubscription
terminate(AtomicReferenceFieldUpdater<F, Subscription>, F) - Static method in class reactor.core.publisher.Operators: Atomically terminates the subscription if it is not already a Operators.cancelledSubscription(), cancelling the subscription and setting the field to the singleton Operators.cancelledSubscription().
terminate(AtomicReferenceFieldUpdater<T, Throwable>, T) - Static method in class reactor.core.Exceptions: Atomic utility to safely mark a volatile throwable reference with a terminal marker.
TERMINATED - Static variable in class reactor.core.Exceptions: A singleton instance of a Throwable indicating a terminal state for exceptions, don't leak this!
TERMINATED - Static variable in class reactor.core.Scannable.Attr: A Boolean attribute indicating whether or not an upstream component terminated this scanned component.
then() - Method in class reactor.core.publisher.Flux: Return a Mono<Void> that completes when this Flux completes.
then() - Method in class reactor.core.publisher.Mono: Return a Mono<Void> which only replays complete and error signals from this Mono.
then() - Method in class reactor.core.publisher.ParallelFlux: Emit an onComplete or onError signal once all values across 'rails' have been observed.
then(Mono<V>) - Method in class reactor.core.publisher.Flux: Let this Flux complete then play signals from a provided Mono.
then(Mono<V>) - Method in class reactor.core.publisher.Mono: Let this Mono complete then play another Mono.
thenEmpty(Publisher<Void>) - Method in class reactor.core.publisher.Flux: Return a Mono<Void> that waits for this Flux to complete then for a supplied Publisher<Void> to also complete.
thenEmpty(Publisher<Void>) - Method in class reactor.core.publisher.Mono: Return a Mono<Void> that waits for this Mono to complete then for a supplied Publisher<Void> to also complete.
thenMany(Publisher<V>) - Method in class reactor.core.publisher.Flux: Let this Flux complete then play another Publisher.
thenMany(Publisher<V>) - Method in class reactor.core.publisher.Mono: Let this Mono complete successfully then play another Publisher.
thenReturn(V) - Method in class reactor.core.publisher.Mono: Let this Mono complete successfully, then emit the provided value.
THREAD_BARRIER - Static variable in interface reactor.core.Fuseable: Indicates that the queue will be drained from another thread thus any queue-exit computation may be invalid at that point.
throwIfFatal(Throwable) - Static method in class reactor.core.Exceptions: Throws a particular Throwable only if it belongs to a set of "fatal" error varieties.
throwIfJvmFatal(Throwable) - Static method in class reactor.core.Exceptions: Throws a particular Throwable only if it belongs to a set of "fatal" error varieties native to the JVM.
timed() - Method in class reactor.core.publisher.Flux: Times Subscriber.onNext(Object) events, encapsulated into a Timed object that lets downstream consumer look at various time information gathered with nanosecond resolution using the default clock (Schedulers.parallel()): Timed.elapsed(): the time in nanoseconds since last event, as a Duration.
timed() - Method in class reactor.core.publisher.Mono: Times this Mono Subscriber.onNext(Object) event, encapsulated into a Timed object that lets downstream consumer look at various time information gathered with nanosecond resolution using the default clock (Schedulers.parallel()): Timed.elapsed(): the time in nanoseconds since subscription, as a Duration.
timed(Scheduler) - Method in class reactor.core.publisher.Flux: Times Subscriber.onNext(Object) events, encapsulated into a Timed object that lets downstream consumer look at various time information gathered with nanosecond resolution using the provided Scheduler as a clock: Timed.elapsed(): the time in nanoseconds since last event, as a Duration.
timed(Scheduler) - Method in class reactor.core.publisher.Mono: Times this Mono Subscriber.onNext(Object) event, encapsulated into a Timed object that lets downstream consumer look at various time information gathered with nanosecond resolution using the provided Scheduler as a clock: Timed.elapsed(): the time in nanoseconds since subscription, as a Duration.
Timed<T> - Interface in reactor.core.publisher
timeout(Duration) - Method in class reactor.core.publisher.Flux: Propagate a TimeoutException as soon as no item is emitted within the given Duration from the previous emission (or the subscription for the first item).
timeout(Duration) - Method in class reactor.core.publisher.Mono: Propagate a TimeoutException in case no item arrives within the given Duration.
timeout(Duration, Publisher<? extends T>) - Method in class reactor.core.publisher.Flux: Switch to a fallback Flux as soon as no item is emitted within the given Duration from the previous emission (or the subscription for the first item).
timeout(Duration, Publisher<? extends T>, Scheduler) - Method in class reactor.core.publisher.Flux: Switch to a fallback Flux as soon as no item is emitted within the given Duration from the previous emission (or the subscription for the first item), as measured on the specified Scheduler.
timeout(Duration, Mono<? extends T>, Scheduler) - Method in class reactor.core.publisher.Mono: Switch to a fallback Mono in case an item doesn't arrive before the given period, as measured on the provided Scheduler.
timeout(Duration, Mono<? extends T>) - Method in class reactor.core.publisher.Mono: Switch to a fallback Mono in case no item arrives within the given Duration.
timeout(Duration, Scheduler) - Method in class reactor.core.publisher.Flux: Propagate a TimeoutException as soon as no item is emitted within the given Duration from the previous emission (or the subscription for the first item), as measured by the specified Scheduler.
timeout(Duration, Scheduler) - Method in class reactor.core.publisher.Mono: Signal a TimeoutException error in case an item doesn't arrive before the given period, as measured on the provided Scheduler.
timeout(Publisher) - Method in class reactor.core.publisher.Flux: Signal a TimeoutException in case the first item from this Flux has not been emitted before the given Publisher emits.
timeout(Publisher) - Method in class reactor.core.publisher.Mono: Signal a TimeoutException in case the item from this Mono has not been emitted before the given Publisher emits.
timeout(Publisher, Function<? super T, ? extends Publisher<V>>) - Method in class reactor.core.publisher.Flux: Signal a TimeoutException in case the first item from this Flux has not been emitted before the firstTimeout Publisher emits, and whenever each subsequent elements is not emitted before a Publisher generated from the latest element signals.
timeout(Publisher, Function<? super T, ? extends Publisher<V>>, Publisher<? extends T>) - Method in class reactor.core.publisher.Flux: Switch to a fallback Publisher in case the first item from this Flux has not been emitted before the firstTimeout Publisher emits, and whenever each subsequent elements is not emitted before a Publisher generated from the latest element signals.
timeout(Publisher, Mono<? extends T>) - Method in class reactor.core.publisher.Mono: Switch to a fallback Publisher in case the item from this Mono has not been emitted before the given Publisher emits.
times(long) - Static method in class reactor.util.repeat.RepeatSpec: Creates a RepeatSpec that repeats n times.
timestamp() - Method in class reactor.core.publisher.Flux: Emit a Tuple2 pair of T1 the current clock time in millis (as a Long measured by the parallel Scheduler) and T2 the emitted data (as a T), for each item from this Flux.
timestamp() - Method in class reactor.core.publisher.Mono: If this Mono is valued, emit a Tuple2 pair of T1 the current clock time in millis (as a Long measured by the parallel Scheduler) and T2 the emitted data (as a T).
timestamp() - Method in interface reactor.core.publisher.Timed: Get the timestamp of the emission of this timed onNext, as an Instant.
timestamp(Scheduler) - Method in class reactor.core.publisher.Flux: Emit a Tuple2 pair of T1 the current clock time in millis (as a Long measured by the provided Scheduler) and T2 the emitted data (as a T), for each item from this Flux.
timestamp(Scheduler) - Method in class reactor.core.publisher.Mono: If this Mono is valued, emit a Tuple2 pair of T1 the current clock time in millis (as a Long measured by the provided Scheduler) and T2 the emitted data (as a T).
toArray() - Method in interface reactor.core.Fuseable.QueueSubscription
toArray() - Method in class reactor.util.function.Tuple2: Turn this Tuple into a plain Object[].
toArray() - Method in class reactor.util.function.Tuple3
toArray() - Method in class reactor.util.function.Tuple4
toArray() - Method in class reactor.util.function.Tuple5
toArray() - Method in class reactor.util.function.Tuple6
toArray() - Method in class reactor.util.function.Tuple7
toArray() - Method in class reactor.util.function.Tuple8
toArray(T1[]) - Method in interface reactor.core.Fuseable.QueueSubscription
toConditionalSubscriber(CoreSubscriber<? super T>) - Static method in class reactor.core.publisher.Operators: If the actual CoreSubscriber is not Fuseable.ConditionalSubscriber, it will apply an adapter which directly maps all Fuseable.ConditionalSubscriber.tryOnNext(Object) to Subscriber.onNext(Object) and always returns true as the result
toCoreSubscriber(Subscriber<? super T>) - Static method in class reactor.core.publisher.Operators: If the actual Subscriber is not a CoreSubscriber, it will apply safe strict wrapping to apply all reactive streams rules including the ones relaxed by internal operators based on CoreSubscriber.
toFluxOrMono(Publisher<? extends T>[]) - Static method in class reactor.core.publisher.Operators
toFluxOrMono(Publisher<T>) - Static method in class reactor.core.publisher.Operators
toFuture() - Method in class reactor.core.publisher.Mono: Transform this Mono into a CompletableFuture completing on onNext or onComplete and failing on onError.
toIterable() - Method in class reactor.core.publisher.Flux: Transform this Flux into a lazy Iterable blocking on Iterator.next() calls.
toIterable(int) - Method in class reactor.core.publisher.Flux: Transform this Flux into a lazy Iterable blocking on Iterator.next() calls.
toIterable(int, Supplier<Queue<T>>) - Method in class reactor.core.publisher.Flux: Transform this Flux into a lazy Iterable blocking on Iterator.next() calls.
toList() - Method in class reactor.util.function.Tuple2: Turn this Tuple into a List<Object>.
toStream() - Method in class reactor.core.publisher.Flux: Transform this Flux into a lazy Stream blocking for each source onNext call.
toStream(int) - Method in class reactor.core.publisher.Flux: Transform this Flux into a lazy Stream blocking for each source onNext call.
toString() - Method in class reactor.core.publisher.BaseSubscriber
toString() - Method in class reactor.core.publisher.Flux
toString() - Method in class reactor.core.publisher.Mono
toString() - Method in class reactor.core.publisher.ParallelFlux
toString() - Method in enum reactor.core.publisher.SignalType
toString() - Method in class reactor.util.function.Tuple2: A Tuple String representation is the comma separated list of values, enclosed in square brackets.
totalRetries() - Method in interface reactor.util.retry.Retry.RetrySignal: The total number of retries since the source first was subscribed to (in other words the number of errors -1 since the source was first subscribed to).
totalRetriesInARow() - Method in interface reactor.util.retry.Retry.RetrySignal: Retry counter resetting after each onNext (in other words the number of errors -1 since the latest onNext).
trace(String) - Method in interface reactor.util.Logger: Log a message at the TRACE level.
trace(String, Object...) - Method in interface reactor.util.Logger: Log a message at the TRACE level according to the specified format and arguments.
trace(String, Throwable) - Method in interface reactor.util.Logger: Log an exception (throwable) at the TRACE level with an accompanying message.
transform(Function<? super Flux<T>, ? extends Publisher<V>>) - Method in class reactor.core.publisher.Flux: Transform this Flux in order to generate a target Flux.
transform(Function<? super Mono<T>, ? extends Publisher<V>>) - Method in class reactor.core.publisher.Mono: Transform this Mono in order to generate a target Mono.
transform(Function<? super ParallelFlux<T>, ParallelFlux>) - Method in class reactor.core.publisher.ParallelFlux: Allows composing operators, in assembly time, on top of this ParallelFlux and returns another ParallelFlux with composed features.
transformDeferred(Function<? super Flux<T>, ? extends Publisher<V>>) - Method in class reactor.core.publisher.Flux: Defer the transformation of this Flux in order to generate a target Flux type.
transformDeferred(Function<? super Mono<T>, ? extends Publisher<V>>) - Method in class reactor.core.publisher.Mono: Defer the given transformation to this Mono in order to generate a target Mono type.
transformDeferredContextual(BiFunction<? super Flux<T>, ? super ContextView, ? extends Publisher<V>>) - Method in class reactor.core.publisher.Flux: Defer the given transformation to this Flux in order to generate a target Flux type.
transformDeferredContextual(BiFunction<? super Mono<T>, ? super ContextView, ? extends Publisher<V>>) - Method in class reactor.core.publisher.Mono: Defer the given transformation to this Mono in order to generate a target Mono type.
transformGroups(Function<? super GroupedFlux<Integer, T>, ? extends Publisher<? extends U>>) - Method in class reactor.core.publisher.ParallelFlux: Allows composing operators off the groups (or 'rails'), as individual GroupedFlux instances keyed by the zero based rail's index.
transientErrors(boolean) - Method in class reactor.util.retry.RetryBackoffSpec: Set the transient error mode, indicating that the strategy being built should use Retry.RetrySignal.totalRetriesInARow() rather than Retry.RetrySignal.totalRetries().
transientErrors(boolean) - Method in class reactor.util.retry.RetrySpec: Set the transient error mode, indicating that the strategy being built should use Retry.RetrySignal.totalRetriesInARow() rather than Retry.RetrySignal.totalRetries().
tryEmitComplete() - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.
tryEmitComplete() - Method in class reactor.core.publisher.ReplayProcessor: Deprecated.
tryEmitComplete() - Method in interface reactor.core.publisher.Sinks.Many: Try to terminate the sequence successfully, generating an onComplete signal.
tryEmitComplete() - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
tryEmitEmpty() - Method in class reactor.core.publisher.SinkOneSerialized
tryEmitEmpty() - Method in interface reactor.core.publisher.Sinks.Empty: Try to complete the Mono without a value, generating only an onComplete signal.
tryEmitError(Throwable) - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.
tryEmitError(Throwable) - Method in class reactor.core.publisher.ReplayProcessor: Deprecated.
tryEmitError(Throwable) - Method in class reactor.core.publisher.SinkOneSerialized
tryEmitError(Throwable) - Method in interface reactor.core.publisher.Sinks.Empty: Try to fail the Mono, generating only an onError signal.
tryEmitError(Throwable) - Method in interface reactor.core.publisher.Sinks.Many: Try to fail the sequence, generating an onError signal.
tryEmitError(Throwable) - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
tryEmitNext(T) - Method in class reactor.core.publisher.EmitterProcessor: Deprecated.
tryEmitNext(T) - Method in class reactor.core.publisher.ReplayProcessor: Deprecated.
tryEmitNext(T) - Method in interface reactor.core.publisher.Sinks.Many: Try emitting a non-null element, generating an onNext signal.
tryEmitNext(T) - Method in class reactor.core.publisher.UnicastProcessor: Deprecated.
tryEmitValue(T) - Method in class reactor.core.publisher.SinkOneSerialized
tryEmitValue(T) - Method in interface reactor.core.publisher.Sinks.One: Try to complete the Mono with an element, generating an onNext signal immediately followed by an onComplete signal.
tryOnNext(T) - Method in interface reactor.core.Fuseable.ConditionalSubscriber: Try consuming the value and return true if successful.
Tuple2<T1,T2> - Class in reactor.util.function: A tuple that holds two non-null values.
Tuple3<T1,T2,T3> - Class in reactor.util.function: A tuple that holds three non-null values.
Tuple4<T1,T2,T3,T4> - Class in reactor.util.function: A tuple that holds four non-null values
Tuple5<T1,T2,T3,T4,T5> - Class in reactor.util.function: A tuple that holds five non-null values
Tuple6<T1,T2,T3,T4,T5,T6> - Class in reactor.util.function: A tuple that holds six values
Tuple7<T1,T2,T3,T4,T5,T6,T7> - Class in reactor.util.function: A tuple that holds seven non-null values
Tuple8<T1,T2,T3,T4,T5,T6,T7,T8> - Class in reactor.util.function: A tuple that holds eight values
Tuples - Class in reactor.util.function: A Tuples is an immutable Collection of objects, each of which can be of an arbitrary type.

U

unbounded() - Static method in class reactor.util.concurrent.Queues
unbounded(int) - Static method in class reactor.util.concurrent.Queues: Returns an unbounded, linked-array-based Queue.
unboundedMultiproducer() - Static method in class reactor.util.concurrent.Queues: Returns an unbounded queue suitable for multi-producer/single-consumer (MPSC) scenarios.
unicast() - Method in interface reactor.core.publisher.Sinks.ManySpec: Help building Sinks.Many that will broadcast signals to a single Subscriber
UnicastProcessor<T> - Class in reactor.core.publisher: Deprecated.
to be removed in 3.5, prefer clear cut usage of Sinks through variations under Sinks.many().unicast().
UnicastProcessor(Queue<T>) - Constructor for class reactor.core.publisher.UnicastProcessor: Deprecated.
UnicastProcessor(Queue<T>, Consumer<? super T>, Disposable) - Constructor for class reactor.core.publisher.UnicastProcessor: Deprecated.
UnicastProcessor(Queue<T>, Disposable) - Constructor for class reactor.core.publisher.UnicastProcessor: Deprecated.
UNKNOWN - Enum constant in enum reactor.core.Scannable.Attr.RunStyle: no guarantees can be given on the running mode (default value, weakest level of guarantee)
unsafe() - Static method in class reactor.core.publisher.Sinks: Return a root spec for more advanced use cases such as building operators.
unwrap(Throwable) - Static method in class reactor.core.Exceptions: Unwrap a particular Throwable only if it is was wrapped via bubble or propagate.
unwrapMultiple(Throwable) - Static method in class reactor.core.Exceptions: Attempt to unwrap a Throwable into a List of Throwables.
unwrapMultipleExcludingTracebacks(Throwable) - Static method in class reactor.core.Exceptions: Attempt to unwrap a Throwable into a List of Throwables, excluding instances that are tracebacks.
update(Disposable) - Method in interface reactor.core.Disposable.Swap: Atomically set the next Disposable on this container and dispose the previous one (if any).
upstream() - Method in class reactor.core.publisher.BaseSubscriber: Return current Subscription
useConsoleLoggers() - Static method in class reactor.util.Loggers: Force the usage of Console-based Loggers, even if SLF4J is available on the classpath.
useCustomLoggers(Function<String, ? extends Logger>) - Static method in class reactor.util.Loggers: Use a custom type of Logger created through the provided Function, which takes a logger name as input.
useJdkLoggers() - Static method in class reactor.util.Loggers: Force the usage of JDK-based Loggers, even if SLF4J is available on the classpath.
useRegistry(MeterRegistry) - Static method in class reactor.util.Metrics.MicrometerConfiguration: Deprecated.
prefer using Micrometer setup in new reactor-core-micrometer module. To be removed at the earliest in 3.6.0.
useSl4jLoggers() - Static method in class reactor.util.Loggers: Force the usage of SL4J-based Loggers, throwing an exception if SLF4J isn't available on the classpath.
useVerboseConsoleLoggers() - Static method in class reactor.util.Loggers: Force the usage of Console-based Loggers, even if SLF4J is available on the classpath.
using(Callable<? extends D>, Function<? super D, ? extends Publisher<? extends T>>) - Static method in class reactor.core.publisher.Flux: Uses an AutoCloseable resource, generated by a supplier for each individual Subscriber, while streaming the values from a Publisher derived from the same resource and makes sure the resource is released if the sequence terminates or the Subscriber cancels.
using(Callable<? extends D>, Function<? super D, ? extends Publisher<? extends T>>, boolean) - Static method in class reactor.core.publisher.Flux: Uses an AutoCloseable resource, generated by a supplier for each individual Subscriber, while streaming the values from a Publisher derived from the same resource and makes sure the resource is released if the sequence terminates or the Subscriber cancels.
using(Callable<? extends D>, Function<? super D, ? extends Publisher<? extends T>>, Consumer<? super D>) - Static method in class reactor.core.publisher.Flux: Uses a resource, generated by a supplier for each individual Subscriber, while streaming the values from a Publisher derived from the same resource and makes sure the resource is released if the sequence terminates or the Subscriber cancels.
using(Callable<? extends D>, Function<? super D, ? extends Publisher<? extends T>>, Consumer<? super D>, boolean) - Static method in class reactor.core.publisher.Flux: Uses a resource, generated by a supplier for each individual Subscriber, while streaming the values from a Publisher derived from the same resource and makes sure the resource is released if the sequence terminates or the Subscriber cancels.
using(Callable<? extends D>, Function<? super D, ? extends Mono<? extends T>>) - Static method in class reactor.core.publisher.Mono: Uses an AutoCloseable resource, generated by a supplier for each individual Subscriber, while streaming the value from a Mono derived from the same resource and makes sure the resource is released if the sequence terminates or the Subscriber cancels.
using(Callable<? extends D>, Function<? super D, ? extends Mono<? extends T>>, boolean) - Static method in class reactor.core.publisher.Mono: Uses an AutoCloseable resource, generated by a supplier for each individual Subscriber, while streaming the value from a Mono derived from the same resource and makes sure the resource is released if the sequence terminates or the Subscriber cancels.
using(Callable<? extends D>, Function<? super D, ? extends Mono<? extends T>>, Consumer<? super D>) - Static method in class reactor.core.publisher.Mono: Uses a resource, generated by a supplier for each individual Subscriber, while streaming the value from a Mono derived from the same resource and makes sure the resource is released if the sequence terminates or the Subscriber cancels.
using(Callable<? extends D>, Function<? super D, ? extends Mono<? extends T>>, Consumer<? super D>, boolean) - Static method in class reactor.core.publisher.Mono: Uses a resource, generated by a supplier for each individual Subscriber, while streaming the value from a Mono derived from the same resource and makes sure the resource is released if the sequence terminates or the Subscriber cancels.
usingWhen(Publisher<D>, Function<? super D, ? extends Publisher<? extends T>>, Function<? super D, ? extends Publisher<?>>) - Static method in class reactor.core.publisher.Flux: Uses a resource, generated by a Publisher for each individual Subscriber, while streaming the values from a Publisher derived from the same resource.
usingWhen(Publisher<D>, Function<? super D, ? extends Publisher<? extends T>>, Function<? super D, ? extends Publisher<?>>, BiFunction<? super D, ? super Throwable, ? extends Publisher<?>>, Function<? super D, ? extends Publisher<?>>) - Static method in class reactor.core.publisher.Flux: Uses a resource, generated by a Publisher for each individual Subscriber, while streaming the values from a Publisher derived from the same resource.
usingWhen(Publisher<D>, Function<? super D, ? extends Mono<? extends T>>, Function<? super D, ? extends Publisher<?>>) - Static method in class reactor.core.publisher.Mono: Uses a resource, generated by a Publisher for each individual Subscriber, to derive a Mono.
usingWhen(Publisher<D>, Function<? super D, ? extends Mono<? extends T>>, Function<? super D, ? extends Publisher<?>>, BiFunction<? super D, ? super Throwable, ? extends Publisher<?>>, Function<? super D, ? extends Publisher<?>>) - Static method in class reactor.core.publisher.Mono: Uses a resource, generated by a Publisher for each individual Subscriber, to derive a Mono.Note that all steps of the operator chain that would need the resource to be in an open stable state need to be described inside the resourceClosure Function.

V

validate(long) - Static method in class reactor.core.publisher.Operators: Evaluate if a request is strictly positive otherwise Operators.reportBadRequest(long)
validate(Subscription, Subscription) - Static method in class reactor.core.publisher.Operators: Check Subscription current state and cancel new Subscription if current is set, or return true if ready to subscribe.
validate(Subscriber<?>[]) - Method in class reactor.core.publisher.ParallelFlux: Validates the number of subscribers and returns true if their number matches the parallelism level of this ParallelFlux.
validateArguments() - Method in class reactor.util.retry.RetryBackoffSpec
value - Variable in class reactor.core.publisher.Operators.MonoSubscriber: The value stored by this Mono operator.
valueOf(String) - Static method in enum reactor.core.publisher.BufferOverflowStrategy: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.core.publisher.FluxSink.OverflowStrategy: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.core.publisher.SignalType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.core.publisher.Sinks.EmitResult: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.core.Scannable.Attr.RunStyle: Returns the enum constant of this type with the specified name.
values() - Static method in enum reactor.core.publisher.BufferOverflowStrategy: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.core.publisher.FluxSink.OverflowStrategy: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.core.publisher.SignalType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.core.publisher.Sinks.EmitResult: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.core.Scannable.Attr.RunStyle: Returns an array containing the constants of this enum type, in the order they are declared.

W

warn(String) - Method in interface reactor.util.Logger: Log a message at the WARN level.
warn(String, Object...) - Method in interface reactor.util.Logger: Log a message at the WARN level according to the specified format and arguments.
warn(String, Throwable) - Method in interface reactor.util.Logger: Log an exception (throwable) at the WARN level with an accompanying message.
warnOrDebug(Logger.ChoiceOfMessageSupplier) - Method in interface reactor.util.Logger: Convenience method to log a message that is different according to the log level.
warnOrDebug(Logger.ChoiceOfMessageSupplier, Throwable) - Method in interface reactor.util.Logger: Convenience method to log an exception (throwable), with an accompanying message that is different according to the log level.
when(Iterable<? extends Publisher<?>>) - Static method in class reactor.core.publisher.Mono: Aggregate given publishers into a new Mono that will be fulfilled when all of the given Publishers have completed.
when(Publisher<?>...) - Static method in class reactor.core.publisher.Mono: Aggregate given publishers into a new Mono that will be fulfilled when all of the given sources have completed.
whenDelayError(Iterable<? extends Publisher<?>>) - Static method in class reactor.core.publisher.Mono: Aggregate given publishers into a new Mono that will be fulfilled when all of the given sources have completed.
whenDelayError(Publisher<?>...) - Static method in class reactor.core.publisher.Mono: Merge given publishers into a new Mono that will be fulfilled when all of the given sources have completed.
window(int) - Method in class reactor.core.publisher.Flux: Split this Flux sequence into multiple Flux windows containing maxSize elements (or less for the final window) and starting from the first item.
window(int, int) - Method in class reactor.core.publisher.Flux: Split this Flux sequence into multiple Flux windows of size maxSize, that each open every skip elements in the source.
window(Duration) - Method in class reactor.core.publisher.Flux: Split this Flux sequence into continuous, non-overlapping windows that open for a windowingTimespan Duration (as measured on the parallel Scheduler).
window(Duration, Duration) - Method in class reactor.core.publisher.Flux: Split this Flux sequence into multiple Flux windows that open for a given windowingTimespan Duration, after which it closes with onComplete.
window(Duration, Duration, Scheduler) - Method in class reactor.core.publisher.Flux: Split this Flux sequence into multiple Flux windows that open for a given windowingTimespan Duration, after which it closes with onComplete.
window(Duration, Scheduler) - Method in class reactor.core.publisher.Flux: Split this Flux sequence into continuous, non-overlapping windows that open for a windowingTimespan Duration (as measured on the provided Scheduler).
window(Publisher<?>) - Method in class reactor.core.publisher.Flux: Split this Flux sequence into continuous, non-overlapping windows where the window boundary is signalled by another Publisher
windowTimeout(int, Duration) - Method in class reactor.core.publisher.Flux: Split this Flux sequence into multiple Flux windows containing maxSize elements (or less for the final window) and starting from the first item.
windowTimeout(int, Duration, boolean) - Method in class reactor.core.publisher.Flux: Split this Flux sequence into multiple Flux windows containing maxSize elements (or less for the final window) and starting from the first item.
windowTimeout(int, Duration, Scheduler) - Method in class reactor.core.publisher.Flux: Split this Flux sequence into multiple Flux windows containing maxSize elements (or less for the final window) and starting from the first item.
windowTimeout(int, Duration, Scheduler, boolean) - Method in class reactor.core.publisher.Flux: Split this Flux sequence into multiple Flux windows containing maxSize elements (or less for the final window) and starting from the first item.
windowUntil(Predicate<T>) - Method in class reactor.core.publisher.Flux: Split this Flux sequence into multiple Flux windows delimited by the given predicate.
windowUntil(Predicate<T>, boolean) - Method in class reactor.core.publisher.Flux: Split this Flux sequence into multiple Flux windows delimited by the given predicate.
windowUntil(Predicate<T>, boolean, int) - Method in class reactor.core.publisher.Flux: Split this Flux sequence into multiple Flux windows delimited by the given predicate and using a prefetch.
windowUntilChanged() - Method in class reactor.core.publisher.Flux: Collect subsequent repetitions of an element (that is, if they arrive right after one another) into multiple Flux windows.
windowUntilChanged(Function<? super T, ? extends V>, BiPredicate<? super V, ? super V>) - Method in class reactor.core.publisher.Flux: Collect subsequent repetitions of an element (that is, if they arrive right after one another), as compared by a key extracted through the user provided Function and compared using a supplied BiPredicate, into multiple Flux windows.
windowUntilChanged(Function<? super T, ? super V>) - Method in class reactor.core.publisher.Flux: Collect subsequent repetitions of an element (that is, if they arrive right after one another), as compared by a key extracted through the user provided Function, into multiple Flux windows.
windowWhen(Publisher, Function<? super U, ? extends Publisher<V>>) - Method in class reactor.core.publisher.Flux: Split this Flux sequence into potentially overlapping windows controlled by items of a start Publisher and end Publisher derived from the start values.
windowWhile(Predicate<T>) - Method in class reactor.core.publisher.Flux: Split this Flux sequence into multiple Flux windows that stay open while a given predicate matches the source elements.
windowWhile(Predicate<T>, int) - Method in class reactor.core.publisher.Flux: Split this Flux sequence into multiple Flux windows that stay open while a given predicate matches the source elements.
withFixedDelay(Duration) - Method in class reactor.util.repeat.RepeatSpec: Applies a fixed delay between repeat iterations.
withLatestFrom(Publisher<? extends U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class reactor.core.publisher.Flux: Combine the most recently emitted values from both this Flux and another Publisher through a BiFunction and emits the result.
withRepeatContext(ContextView) - Method in class reactor.util.repeat.RepeatSpec: Set the user provided contextView that can be used to manipulate state on retries.
withRetryContext(ContextView) - Method in class reactor.util.retry.RetryBackoffSpec: Set the user provided context that can be used to manipulate state on retries.
withRetryContext(ContextView) - Method in class reactor.util.retry.RetrySpec: Set the user provided context that can be used to manipulate state on retries.
withScheduler(Scheduler) - Method in class reactor.util.repeat.RepeatSpec: Sets a Scheduler to use for delaying repeat attempts.
withThrowable(Function<Flux<Throwable>, ? extends Publisher<?>>) - Static method in class reactor.util.retry.Retry: An adapter for Flux of Throwable-based Function to provide Retry from a legacy retryWhen Function.
wrap(Subscriber<IN>, Publisher<OUT>) - Static method in class reactor.core.publisher.FluxProcessor: Deprecated.

Transform a receiving Subscriber and a producing Publisher in a logical FluxProcessor.
wrapQueue(Queue<T>) - Static method in class reactor.core.publisher.Hooks: Applies the Queue wrappers that were previously registered.
wrapSource(Throwable) - Static method in class reactor.core.Exceptions: Wrap a Throwable delivered via Subscriber.onError(Throwable) from an upstream Publisher that itself emits Publishers to distinguish the error signal from the inner sequence's processing errors.
writeableType() - Method in class reactor.util.context.ReactorContextAccessor
writeValues(Map<Object, Object>, Context) - Method in class reactor.util.context.ReactorContextAccessor

X

xs() - Static method in class reactor.util.concurrent.Queues
XS_BUFFER_SIZE - Static variable in class reactor.util.concurrent.Queues: An allocation friendly default of available slots in a given container, e.g.

Z

zip(Iterable<? extends Publisher<?>>, int, Function<? super Object[], ? extends O>) - Static method in class reactor.core.publisher.Flux: Zip multiple sources together, that is to say wait for all the sources to emit one element and combine these elements once into an output value (constructed by the provided combinator).
zip(Iterable<? extends Publisher<?>>, Function<? super Object[], ? extends O>) - Static method in class reactor.core.publisher.Flux: Zip multiple sources together, that is to say wait for all the sources to emit one element and combine these elements once into an output value (constructed by the provided combinator).
zip(Iterable<? extends Mono<?>>, Function<? super Object[], ? extends R>) - Static method in class reactor.core.publisher.Mono: Aggregate given monos into a new Mono that will be fulfilled when all of the given Monos have produced an item, aggregating their values according to the provided combinator function.
zip(Function<? super Object[], ? extends O>, int, Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux: Zip multiple sources together, that is to say wait for all the sources to emit one element and combine these elements once into an output value (constructed by the provided combinator).
zip(Function<? super Object[], ? extends O>, Publisher<? extends I>...) - Static method in class reactor.core.publisher.Flux: Zip multiple sources together, that is to say wait for all the sources to emit one element and combine these elements once into an output value (constructed by the provided combinator).
zip(Function<? super Object[], ? extends R>, Mono<?>...) - Static method in class reactor.core.publisher.Mono: Aggregate given monos into a new Mono that will be fulfilled when all of the given Monos have produced an item, aggregating their values according to the provided combinator function.
zip(Publisher<? extends Publisher<?>>, Function<? super TUPLE, ? extends V>) - Static method in class reactor.core.publisher.Flux: Zip multiple sources together, that is to say wait for all the sources to emit one element and combine these elements once into an output value (constructed by the provided combinator).
zip(Publisher<? extends T1>, Publisher<? extends T2>) - Static method in class reactor.core.publisher.Flux: Zip two sources together, that is to say wait for all the sources to emit one element and combine these elements once into a Tuple2.
zip(Publisher<? extends T1>, Publisher<? extends T2>, BiFunction<? super T1, ? super T2, ? extends O>) - Static method in class reactor.core.publisher.Flux: Zip two sources together, that is to say wait for all the sources to emit one element and combine these elements once into an output value (constructed by the provided combinator).
zip(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>) - Static method in class reactor.core.publisher.Flux: Zip three sources together, that is to say wait for all the sources to emit one element and combine these elements once into a Tuple3.
zip(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Publisher<? extends T4>) - Static method in class reactor.core.publisher.Flux: Zip four sources together, that is to say wait for all the sources to emit one element and combine these elements once into a Tuple4.
zip(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Publisher<? extends T4>, Publisher<? extends T5>) - Static method in class reactor.core.publisher.Flux: Zip five sources together, that is to say wait for all the sources to emit one element and combine these elements once into a Tuple5.
zip(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Publisher<? extends T4>, Publisher<? extends T5>, Publisher<? extends T6>) - Static method in class reactor.core.publisher.Flux: Zip six sources together, that is to say wait for all the sources to emit one element and combine these elements once into a Tuple6.
zip(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Publisher<? extends T4>, Publisher<? extends T5>, Publisher<? extends T6>, Publisher<? extends T7>) - Static method in class reactor.core.publisher.Flux: Zip seven sources together, that is to say wait for all the sources to emit one element and combine these elements once into a Tuple7.
zip(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Publisher<? extends T4>, Publisher<? extends T5>, Publisher<? extends T6>, Publisher<? extends T7>, Publisher<? extends T8>) - Static method in class reactor.core.publisher.Flux: Zip eight sources together, that is to say wait for all the sources to emit one element and combine these elements once into a Tuple8.
zip(Mono<? extends T1>, Mono<? extends T2>) - Static method in class reactor.core.publisher.Mono: Merge given monos into a new Mono that will be fulfilled when all of the given Monos have produced an item, aggregating their values into a Tuple2.
zip(Mono<? extends T1>, Mono<? extends T2>, BiFunction<? super T1, ? super T2, ? extends O>) - Static method in class reactor.core.publisher.Mono: Merge given monos into a new Mono that will be fulfilled when all of the given Monos have produced an item, aggregating their values as defined by the combinator function.
zip(Mono<? extends T1>, Mono<? extends T2>, Mono<? extends T3>) - Static method in class reactor.core.publisher.Mono: Merge given monos into a new Mono that will be fulfilled when all of the given Monos have produced an item, aggregating their values into a Tuple3.
zip(Mono<? extends T1>, Mono<? extends T2>, Mono<? extends T3>, Mono<? extends T4>) - Static method in class reactor.core.publisher.Mono: Merge given monos into a new Mono that will be fulfilled when all of the given Monos have produced an item, aggregating their values into a Tuple4.
zip(Mono<? extends T1>, Mono<? extends T2>, Mono<? extends T3>, Mono<? extends T4>, Mono<? extends T5>) - Static method in class reactor.core.publisher.Mono: Merge given monos into a new Mono that will be fulfilled when all of the given Monos have produced an item, aggregating their values into a Tuple5.
zip(Mono<? extends T1>, Mono<? extends T2>, Mono<? extends T3>, Mono<? extends T4>, Mono<? extends T5>, Mono<? extends T6>) - Static method in class reactor.core.publisher.Mono: Merge given monos into a new Mono that will be fulfilled when all of the given Monos have produced an item, aggregating their values into a Tuple6.
zip(Mono<? extends T1>, Mono<? extends T2>, Mono<? extends T3>, Mono<? extends T4>, Mono<? extends T5>, Mono<? extends T6>, Mono<? extends T7>) - Static method in class reactor.core.publisher.Mono: Merge given monos into a new Mono that will be fulfilled when all of the given Monos have produced an item, aggregating their values into a Tuple7.
zip(Mono<? extends T1>, Mono<? extends T2>, Mono<? extends T3>, Mono<? extends T4>, Mono<? extends T5>, Mono<? extends T6>, Mono<? extends T7>, Mono<? extends T8>) - Static method in class reactor.core.publisher.Mono: Merge given monos into a new Mono that will be fulfilled when all of the given Monos have produced an item, aggregating their values into a Tuple8.
zipDelayError(Iterable<? extends Mono<?>>, Function<? super Object[], ? extends R>) - Static method in class reactor.core.publisher.Mono: Aggregate given monos into a new Mono that will be fulfilled when all of the given Monos have produced an item.
zipDelayError(Function<? super Object[], ? extends R>, Mono<?>...) - Static method in class reactor.core.publisher.Mono: Merge given monos into a new Mono that will be fulfilled when all of the given Monos have produced an item, aggregating their values according to the provided combinator function and delaying errors.
zipDelayError(Mono<? extends T1>, Mono<? extends T2>) - Static method in class reactor.core.publisher.Mono: Merge given monos into a new Mono that will be fulfilled when all of the given Monos have produced an item, aggregating their values into a Tuple2 and delaying errors.
zipDelayError(Mono<? extends T1>, Mono<? extends T2>, Mono<? extends T3>) - Static method in class reactor.core.publisher.Mono: Merge given monos into a new Mono that will be fulfilled when all of the given Mono Monos have produced an item, aggregating their values into a Tuple3 and delaying errors.
zipDelayError(Mono<? extends T1>, Mono<? extends T2>, Mono<? extends T3>, Mono<? extends T4>) - Static method in class reactor.core.publisher.Mono: Merge given monos into a new Mono that will be fulfilled when all of the given Monos have produced an item, aggregating their values into a Tuple4 and delaying errors.
zipDelayError(Mono<? extends T1>, Mono<? extends T2>, Mono<? extends T3>, Mono<? extends T4>, Mono<? extends T5>) - Static method in class reactor.core.publisher.Mono: Merge given monos into a new Mono that will be fulfilled when all of the given Monos have produced an item, aggregating their values into a Tuple5 and delaying errors.
zipDelayError(Mono<? extends T1>, Mono<? extends T2>, Mono<? extends T3>, Mono<? extends T4>, Mono<? extends T5>, Mono<? extends T6>) - Static method in class reactor.core.publisher.Mono: Merge given monos into a new Mono that will be fulfilled when all of the given Monos have produced an item, aggregating their values into a Tuple6 and delaying errors.
zipDelayError(Mono<? extends T1>, Mono<? extends T2>, Mono<? extends T3>, Mono<? extends T4>, Mono<? extends T5>, Mono<? extends T6>, Mono<? extends T7>) - Static method in class reactor.core.publisher.Mono: Merge given monos into a new Mono that will be fulfilled when all of the given Monos have produced an item, aggregating their values into a Tuple7 and delaying errors.
zipDelayError(Mono<? extends T1>, Mono<? extends T2>, Mono<? extends T3>, Mono<? extends T4>, Mono<? extends T5>, Mono<? extends T6>, Mono<? extends T7>, Mono<? extends T8>) - Static method in class reactor.core.publisher.Mono: Merge given monos into a new Mono that will be fulfilled when all of the given Monos have produced an item, aggregating their values into a Tuple8 and delaying errors.
zipWhen(Function<T, Mono<? extends T2>>) - Method in class reactor.core.publisher.Mono: Wait for the result from this mono, use it to create a second mono via the provided rightGenerator function and combine both results into a Tuple2.
zipWhen(Function<T, Mono<? extends T2>>, BiFunction<T, T2, O>) - Method in class reactor.core.publisher.Mono: Wait for the result from this mono, use it to create a second mono via the provided rightGenerator function and combine both results into an arbitrary O object, as defined by the provided combinator function.
zipWith(Publisher<? extends T2>) - Method in class reactor.core.publisher.Flux: Zip this Flux with another Publisher source, that is to say wait for both to emit one element and combine these elements once into a Tuple2.
zipWith(Publisher<? extends T2>, int) - Method in class reactor.core.publisher.Flux: Zip this Flux with another Publisher source, that is to say wait for both to emit one element and combine these elements once into a Tuple2.
zipWith(Publisher<? extends T2>, int, BiFunction<? super T, ? super T2, ? extends V>) - Method in class reactor.core.publisher.Flux: Zip this Flux with another Publisher source, that is to say wait for both to emit one element and combine these elements using a combinator BiFunction The operator will continue doing so until any of the sources completes.
zipWith(Publisher<? extends T2>, BiFunction<? super T, ? super T2, ? extends V>) - Method in class reactor.core.publisher.Flux: Zip this Flux with another Publisher source, that is to say wait for both to emit one element and combine these elements using a combinator BiFunction The operator will continue doing so until any of the sources completes.
zipWith(Mono<? extends T2>) - Method in class reactor.core.publisher.Mono: Combine the result from this mono and another into a Tuple2.
zipWith(Mono<? extends T2>, BiFunction<? super T, ? super T2, ? extends O>) - Method in class reactor.core.publisher.Mono: Combine the result from this mono and another into an arbitrary O object, as defined by the provided combinator function.
zipWithIterable(Iterable<? extends T2>) - Method in class reactor.core.publisher.Flux: Zip elements from this Flux with the content of an Iterable, that is to say combine one element from each, pairwise, into a Tuple2.
zipWithIterable(Iterable<? extends T2>, BiFunction<? super T, ? super T2, ? extends V>) - Method in class reactor.core.publisher.Flux: Zip elements from this Flux with the content of an Iterable, that is to say combine one element from each, pairwise, using the given zipper BiFunction.

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
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form