Index (Reactor Core 3.1.0.M1)

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

A

accept(Subscriber<? super T>) - Method in class 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
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(T) - Method in class reactor.util.concurrent.OpenHashSet
addAll(Collection<? extends T>) - Method in interface reactor.core.Fuseable.QueueSubscription
addAndGet(AtomicLongFieldUpdater<T>, T, long) - Static method in class reactor.core.publisher.Operators: Concurrent addition bound to Long.MAX_VALUE.
addCap(long, long) - Static method in class reactor.core.publisher.Operators: Cap an addition to Long.MAX_VALUE
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.
alert() - Static method in class reactor.util.concurrent.WaitStrategy: Throw an Alert signal exception (singleton) that can be checked against WaitStrategy.isAlert(Throwable)
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(Mono<? extends T2>) - Method in class reactor.core.publisher.Mono: Combine the result from this mono and another into a Tuple2.
and(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.
and(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.
and(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.
ANY - Static variable in interface reactor.core.Fuseable: Indicates the QueueSubscription should decide what fusion it performs (input only).
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.
apply(Object) - Method in class reactor.util.function.Tuples
argumentIsNullException() - Static method in class reactor.core.Exceptions
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(Subscription) - Static method in class reactor.core.publisher.Operators: Returns the subscription as QueueSubscription if possible or null.
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.
ASYNC - Static variable in interface reactor.core.Fuseable: Indicates the QueueSubscription can perform only async-fusion.
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 runnable that allows disconnecting.
awaitOnSubscribe() - Method in class reactor.core.publisher.Flux: Intercepts the onSubscribe call and makes sure calls to Subscription methods only happen after the child Subscriber has returned from its onSubscribe method.
awaitOnSubscribe() - Method in class reactor.core.publisher.Mono: Intercepts the onSubscribe call and makes sure calls to Subscription methods only happen after the child Subscriber has returned from its onSubscribe method.

B

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(Duration) - Method in class reactor.core.publisher.Mono: Subscribe to this Mono and block until a next signal is received or a timeout expires.
block() - Method in class reactor.core.publisher.MonoProcessor
block(Duration) - Method in class reactor.core.publisher.MonoProcessor: Block the calling thread for the specified time, waiting for the completion of this MonoProcessor.
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.
blocking() - Static method in class reactor.util.concurrent.WaitStrategy: Blocking strategy that uses a lock and condition variable for consumer waiting on a barrier.
blockLast() - Method in class reactor.core.publisher.Flux: Subscribe to this Flux and block indefinitely until the upstream signals its first value or completes.
blockLast(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.
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, 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, 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(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(Duration) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple List buffers that will be emitted by the returned Flux every timespan.
buffer(Duration, Duration) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple List buffers created at a given timeshift period.
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 timespan, as measured on the provided Scheduler.
buffer(Duration, Duration, Scheduler) - Method in class reactor.core.publisher.Flux: Collect incoming values into multiple List buffers created at a given timeshift period, as measured on the provided Scheduler.
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 timespan 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 timespan 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 timespan 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 timespan 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.
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.
busySpin() - Static method in class reactor.util.concurrent.WaitStrategy: Busy Spin strategy that uses a busy spin loop for consumers waiting on a barrier.

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(int) - 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(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() - Method in class reactor.core.publisher.Mono: Turn this Mono into a hot source and cache last emitted signals for further Subscriber.
cacheLast() - Static method in class reactor.core.publisher.ReplayProcessor: Create a ReplayProcessor from hot-cold ReplayProcessor that will not propagate cancel upstream if Subscription has been set.
cacheLastOrDefault(T) - Static method in class reactor.core.publisher.ReplayProcessor: Create a ReplayProcessor from hot-cold ReplayProcessor that will not propagate cancel upstream if Subscription has been set.
call() - Method in interface reactor.core.Fuseable.ScalarCallable
cancel() - Method in class reactor.core.publisher.BaseSubscriber
cancel() - Method in class reactor.core.publisher.MonoProcessor
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
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.
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.QueueSupplier: Calculate the next power of 2, greater than or equal to x.
checkpoint() - Method in class reactor.core.publisher.Flux: Activate assembly tracing for this particular Flux, in case of an error upstream of the checkpoint.
checkpoint(String) - Method in class reactor.core.publisher.Flux: Activate assembly tracing for this particular Flux and give it a description that will be reflected in the assembly traceback in case of an error upstream of the checkpoint.
checkpoint() - Method in class reactor.core.publisher.Mono: Activate assembly tracing for this particular Mono, in case of an error upstream of the checkpoint.
checkpoint(String) - Method in class reactor.core.publisher.Mono: Activate assembly tracing for this particular Mono and give it a description that will be reflected in the assembly traceback, in case of an error upstream of the checkpoint.
checkpoint() - Method in class reactor.core.publisher.ParallelFlux: Activate assembly tracing for this particular ParallelFlux, in case of an error upstream of the checkpoint.
checkpoint(String) - Method in class reactor.core.publisher.ParallelFlux: Activate assembly tracing for this particular ParallelFlux and give it a description that will be reflected in the assembly traceback, in case of an error upstream of the checkpoint.
checkRequest(long) - Static method in class reactor.core.publisher.Operators: Throws an exception if request is 0 or negative as specified in rule 3.09 of Reactive Streams
checkRequest(long, Subscriber<?>) - Static method in class reactor.core.publisher.Operators: Propagate an exception to a subscriber if request is 0 or negative, as specified in rule 3.09 of Reactive Streams
clear() - Method in class reactor.core.publisher.Operators.MonoSubscriber
clear() - Method in class reactor.core.publisher.UnicastProcessor
clear(Consumer<? super T>) - Method in class reactor.util.concurrent.OpenHashSet
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.
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.
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.
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.
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.
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.
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.
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.
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.
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(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(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(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.
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(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.
complete() - Method in interface reactor.core.publisher.FluxSink
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(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() - Static method in class reactor.core.publisher.Signal: Creates and returns a Signal of variety Type.COMPLETE.
complete() - Method in interface reactor.core.publisher.SynchronousSink
compose(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.
compose(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.
composeGroup(Function<? super GroupedFlux<Integer, T>, ? extends Publisher<? extends U>>) - Method in class reactor.core.publisher.ParallelFlux: Allows composing operators off the 'rails', as individual GroupedFlux instances keyed by the zero based rail's index.
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>>, 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>>, 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 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 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.
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.
concatMapDelayError(Function<? super T, 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>>, 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>>, 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 R>>) - Method in class reactor.core.publisher.ParallelFlux: Generates and concatenates Publishers on each 'rail', delaying errors and generating 2 publishers upfront.
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).
connect() - Method in class reactor.core.publisher.ConnectableFlux: Connect this ConnectableFlux to its source and return a Runnable 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
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: Create a new DirectProcessor
create() - Static method in class reactor.core.publisher.EmitterProcessor: Create a new EmitterProcessor using QueueSupplier.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and auto-cancel.
create(boolean) - Static method in class reactor.core.publisher.EmitterProcessor: Create a new EmitterProcessor using QueueSupplier.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and auto-cancel.
create(int) - Static method in class reactor.core.publisher.EmitterProcessor: Create a new EmitterProcessor using QueueSupplier.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and auto-cancel.
create(int, boolean) - Static method in class reactor.core.publisher.EmitterProcessor: Create a new EmitterProcessor using QueueSupplier.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and auto-cancel.
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() - Static method in class reactor.core.publisher.MonoProcessor: Create a MonoProcessor that will eagerly request 1 on MonoProcessor.onSubscribe(Subscription), cache and emit the eventual result for 1 or N subscribers.
create(WaitStrategy) - Static method in class reactor.core.publisher.MonoProcessor: Create a MonoProcessor that will eagerly request 1 on MonoProcessor.onSubscribe(Subscription), cache and emit the eventual result for 1 or N subscribers.
create() - Static method in class reactor.core.publisher.ReplayProcessor: Create a new ReplayProcessor using QueueSupplier.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and auto-cancel.
create(int) - Static method in class reactor.core.publisher.ReplayProcessor: Create a new ReplayProcessor using a provided backlog size, blockingWait Strategy and auto-cancel.
create(int, boolean) - Static method in class reactor.core.publisher.ReplayProcessor: Create a new ReplayProcessor using a provided backlog size, blockingWait Strategy and auto-cancel.
create() - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using QueueSupplier.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and auto-cancel.
create(String) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using QueueSupplier.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and auto-cancel.
create(boolean) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using QueueSupplier.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and the passed auto-cancel setting.
create(ExecutorService) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using QueueSupplier.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and auto-cancel.
create(ExecutorService, boolean) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using QueueSupplier.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and the passed auto-cancel setting.
create(String, int) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using QueueSupplier.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and the passed auto-cancel setting.
create(String, int, boolean) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using the blockingWait Strategy, passed backlog size, and auto-cancel settings.
create(ExecutorService, int) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using passed backlog size, blockingWait Strategy and will auto-cancel.
create(ExecutorService, int, boolean) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using passed backlog size, blockingWait Strategy and the auto-cancel argument.
create(String, int, WaitStrategy) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using passed backlog size, wait strategy and will auto-cancel.
create(String, int, WaitStrategy, Supplier<E>) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using passed backlog size, wait strategy, signal supplier.
create(String, int, WaitStrategy, boolean) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using passed backlog size, wait strategy and auto-cancel settings.
create(ExecutorService, int, WaitStrategy) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using passed backlog size, wait strategy and will auto-cancel.
create(ExecutorService, int, WaitStrategy, boolean) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using passed backlog size, wait strategy and auto-cancel settings.
create(ExecutorService, ExecutorService, int, WaitStrategy, boolean) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using passed backlog size, wait strategy and auto-cancel settings.
create() - Static method in class reactor.core.publisher.UnicastProcessor: Create a unicast FluxProcessor that will buffer on a given queue in an unbounded fashion.
create(Queue<T>) - Static method in class reactor.core.publisher.UnicastProcessor: Create a unicast FluxProcessor that will buffer on a given queue in an unbounded fashion.
create(Queue<T>, Disposable) - Static method in class reactor.core.publisher.UnicastProcessor: Create a unicast FluxProcessor that will buffer on a given queue in an unbounded fashion.
create(Queue<T>, Consumer<? super T>, Disposable) - Static method in class reactor.core.publisher.UnicastProcessor: Create a unicast FluxProcessor that will buffer on a given queue in an unbounded fashion.
create() - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new WorkQueueProcessor using QueueSupplier.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and auto-cancel.
create(boolean) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new WorkQueueProcessor using QueueSupplier.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and the passed auto-cancel setting.
create(ExecutorService) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new WorkQueueProcessor using QueueSupplier.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and auto-cancel.
create(ExecutorService, boolean) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new WorkQueueProcessor using QueueSupplier.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and the passed auto-cancel setting.
create(String) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new TopicProcessor using the default buffer size 32, blockingWait Strategy and auto-cancel.
create(String, int) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new TopicProcessor using the passed buffer size, blockingWait Strategy and auto-cancel.
create(String, int, boolean) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new TopicProcessor using the passed buffer size, blockingWait Strategy and the passed auto-cancel setting.
create(ExecutorService, int) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new TopicProcessor using the passed buffer size, blockingWait Strategy and auto-cancel.
create(ExecutorService, int, boolean) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new WorkQueueProcessor using the passed buffer size, blockingWait Strategy and auto-cancel.
create(String, int, WaitStrategy) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new WorkQueueProcessor using the passed buffer size, blockingWait Strategy and auto-cancel.
create(String, int, WaitStrategy, boolean) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new WorkQueueProcessor using the passed buffer size, blockingWait Strategy and auto-cancel settings.
create(ExecutorService, int, WaitStrategy) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new WorkQueueProcessor using the passed buffer size and blockingWait Strategy settings but will auto-cancel.
create(ExecutorService, int, WaitStrategy, boolean) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new WorkQueueProcessor using the passed buffer size, wait strategy and auto-cancel settings.
create(ExecutorService, ExecutorService, int, WaitStrategy, boolean) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new WorkQueueProcessor using the passed buffer size, wait strategy and auto-cancel settings.
createSizeAndTimeout(int, Duration) - Static method in class reactor.core.publisher.ReplayProcessor: Creates a time- and size-bounded replay processor.
createSizeAndTimeout(int, Duration, Scheduler) - Static method in class reactor.core.publisher.ReplayProcessor: Creates a time- and size-bounded replay processor.
createTimeout(Duration) - Static method in class reactor.core.publisher.ReplayProcessor: Creates a time-bounded replay processor.
createTimeout(Duration, Scheduler) - Static method in class reactor.core.publisher.ReplayProcessor: Creates a time-bounded replay processor.
createWorker() - Method in interface reactor.core.scheduler.Scheduler: Creates a worker of this Scheduler that executed task in a strict FIFO order, guaranteed non-concurrently with each other.

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(String, Supplier<? extends ExecutorService>) - Method in interface reactor.core.scheduler.Schedulers.Factory: Override this method to decorate ExecutorService internally used by Reactor's various Scheduler implementations, allowing to tune the ExecutorService backing implementation.
decorateScheduledExecutorService(String, Supplier<? extends ScheduledExecutorService>) - Method in interface reactor.core.scheduler.Schedulers.Factory: Override this method to decorate ScheduledExecutorService internally used by Reactor's various Scheduler implementations, allowing to tune the ScheduledExecutorService backing implementation.
DEFAULT_POOL_SIZE - Static variable in class reactor.core.scheduler.Schedulers: Default pool size, initialized to the number of processors available to the runtime on init (but with a minimum value of 4).
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
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.
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.
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.
delaySubscription(Duration) - Method in class reactor.core.publisher.Flux: Delay the subscription to this Flux 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(Publisher) - Method in class reactor.core.publisher.Flux: Delay the subscription to this Flux source until another Publisher signals a value or completes.
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.Mono: Delay the subscription to this Mono source until the given Duration elapses.
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.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.
delayUntilOther(Publisher<?>) - Method in class reactor.core.publisher.Mono: Subscribe to this Mono and another Publisher, which will be used as a trigger for the emission of this Mono's element.
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.
DirectProcessor<T> - Class in reactor.core.publisher: Dispatches onNext, onError and onComplete signals to zero-to-many Subscribers.
Disposable - Interface in reactor.core: Indicates that a task or resource can be cancelled/disposed.
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
dispose() - Method in class reactor.core.publisher.MonoProcessor
dispose() - Method in interface reactor.core.scheduler.Scheduler: Instructs this Scheduler to release all resources and reject any new tasks to be executed.
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.
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.
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(BiConsumer<? super T, Throwable>) - Method in class reactor.core.publisher.Mono: Add behavior 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.
doComplete() - Method in class reactor.core.publisher.TopicProcessor
doComplete() - Method in class reactor.core.publisher.WorkQueueProcessor
doError(Throwable) - Method in class reactor.core.publisher.TopicProcessor
doError(Throwable) - Method in class reactor.core.publisher.WorkQueueProcessor
doFinally(Consumer<SignalType>) - Method in class reactor.core.publisher.Flux: Add behavior (side-effect) triggered afterthe 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.
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(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.
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 T>, Consumer<? super Throwable>, Runnable, Runnable) - Method in class reactor.core.publisher.Hooks.OperatorHook: Peek into sequence signals.
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(Consumer<? super Throwable>) - Method in class reactor.core.publisher.Flux: Add behavior (side-effect) triggered when the Flux completes with an error.
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(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(Consumer<? super Throwable>) - Method in class reactor.core.publisher.Mono: Add behavior triggered when the Mono completes with an error.
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(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.
doOnError(Consumer<? super Throwable>) - Method in class reactor.core.publisher.ParallelFlux: Call the specified consumer with the exception passing through any 'rail'.
doOnLifecycle(Consumer<? super Subscription>, LongConsumer, Runnable) - Method in class reactor.core.publisher.Hooks.OperatorHook: Peek into lifecycle signals.
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'.
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 subscribed.
doOnSubscribe(Consumer<? super Subscription>) - Method in class reactor.core.publisher.Mono: Add behavior triggered when the Mono is subscribed.
doOnSubscribe(Consumer<? super Subscription>) - Method in class reactor.core.publisher.ParallelFlux: Call the specified callback when a 'rail' receives a Subscription from its upstream.
doOnSuccess(Consumer<? super T>) - Method in class reactor.core.publisher.Mono: Add behavior triggered when the Mono completes successfully.
doOnTerminate(Runnable) - Method in class reactor.core.publisher.Flux: Add behavior (side-effect) triggered when the Flux terminates, either by completing successfully or with an error.
doOnTerminate(BiConsumer<? super T, Throwable>) - Method in class reactor.core.publisher.Mono: Add behavior triggered when the Mono terminates, either by completing successfully or 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
downstreamCount() - Method in class reactor.core.publisher.EmitterProcessor
downstreamCount() - Method in class reactor.core.publisher.FluxProcessor: Return the number of active Subscriber or -1 if untracked.
downstreamCount() - Method in class reactor.core.publisher.MonoProcessor: Return the number of active Subscriber or -1 if untracked.
downstreamCount() - Method in class reactor.core.publisher.ReplayProcessor
downstreamCount() - Method in class reactor.core.publisher.UnicastProcessor
drain() - Method in class reactor.core.publisher.TopicProcessor
drain() - Method in class reactor.core.publisher.WorkQueueProcessor
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.
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(Scheduler) - 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(Scheduler) - Method in class reactor.core.publisher.Mono: Map this Mono sequence into Tuple2<Long, T> of timemillis and source data.
elastic() - Static method in class reactor.core.scheduler.Schedulers: Scheduler that dynamically creates ExecutorService-based Workers and caches the thread pools, reusing them once the Workers have been shut down.
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.
EmitterProcessor<T> - Class in reactor.core.publisher: * An implementation of a RingBuffer backed message-passing Processor implementing publish-subscribe with synchronous (thread-stealing and happen-before interactions) drain loops.
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(Publisher<T>) - Static method in class reactor.core.publisher.Mono: Create a new Mono from a Publisher that ignores its onNext signals (dropping the emitted items) and only react to completion signal.
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.
equals(Object) - Method in class reactor.core.publisher.Signal
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(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, 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) - Method in interface reactor.core.publisher.FluxSink
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 give exception
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(Throwable) - Static method in class 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(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.
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.
Exceptions - Class in reactor.core: Global Reactor Core Exception handling and utils to operate on.

F

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
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>>, int) - 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.
first(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.
first(Iterable<? extends Mono<? extends T>>) - Static method in class reactor.core.publisher.Mono: Pick the first available result coming from any of the given monos and populate a new Mono.
firstEmitting(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.
firstEmitting(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.
firstEmittingWith(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.
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 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 Publisher<? extends R>>, Function<? super Throwable, ? extends Publisher<? extends R>>, Supplier<? 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 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).
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.
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>>, 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.
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.
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<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
flux() - Method in class reactor.core.publisher.Mono: Convert this Mono to a Flux
FluxProcessor<IN,OUT> - Class in reactor.core.publisher: A base processor that exposes Flux API for Processor.
FluxProcessor() - Constructor for class reactor.core.publisher.FluxProcessor
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.
FluxSource<I,O> - Class in reactor.core.publisher: A connecting Flux Publisher (right-to-left from a composition chain perspective)
FluxSource(Publisher<? extends I>) - Constructor for class reactor.core.publisher.FluxSource: Build a FluxSource wrapper around the passed parent Publisher
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.
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.
from(Object) - Static method in interface reactor.core.Scannable: Attempt to cast the Object to a Scannable.
fromArray(T[]) - Static method in class reactor.core.publisher.Flux: Create a Flux that emits the items contained in the provided array.
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.
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.
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 check if the source is already a Mono, nor cancels 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, boolean) - 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.
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(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 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.

G

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.
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.
get() - Method in class reactor.core.publisher.MutableNextSignal
get() - Method in class reactor.core.publisher.Signal: Retrieves the item associated with this (onNext) signal.
get(int) - Static method in class reactor.util.concurrent.QueueSupplier
get() - Method in class reactor.util.concurrent.QueueSupplier
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
getAndAddCap(AtomicLongFieldUpdater<T>, T, long) - Static method in class reactor.core.publisher.Operators: Concurrent addition bound to Long.MAX_VALUE.
getAsLong() - Method in class reactor.core.publisher.MonoProcessor: Returns the internal state from -1 Cancelled to 5 errored, beyond 3 included is fulfilled.
getBufferSize() - Method in class reactor.core.publisher.EmitterProcessor
getBufferSize() - Method in class reactor.core.publisher.FluxProcessor: Return the processor buffer capacity if any or Integer.MAX_VALUE
getError() - Method in class reactor.core.publisher.DirectProcessor
getError() - Method in class reactor.core.publisher.EmitterProcessor
getError() - Method in class reactor.core.publisher.FluxProcessor: Current error if any, default to null
getError() - Method in class reactor.core.publisher.MonoProcessor: Return the produced Throwable error if any or null
getError() - Method in class reactor.core.publisher.UnicastProcessor
getLogger(String) - 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(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.
getName() - Method in interface reactor.util.Logger: Return the name of this Logger instance.
getPending() - Method in class reactor.core.publisher.EmitterProcessor: Return the number of parked elements in the emitter backlog.
getPending() - Method in class reactor.core.publisher.TopicProcessor
getPending() - Method in class reactor.core.publisher.WorkQueueProcessor
getPrefetch() - Method in class reactor.core.publisher.DirectProcessor
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
getPrefetch() - Method in class reactor.core.publisher.UnicastProcessor
getSubscription() - Method in class reactor.core.publisher.MutableNextSignal
getSubscription() - Method in class 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 fist 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 class reactor.core.publisher.MutableNextSignal
getThrowable() - Method in class reactor.core.publisher.Signal: Read the error associated with this (onError) signal.
getType() - Method in class reactor.core.publisher.MutableNextSignal
getType() - Method in class 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.
hasCompleted() - Method in class reactor.core.publisher.DirectProcessor: Return true if terminated with onComplete
hasDownstreams() - Method in class reactor.core.publisher.DirectProcessor
hasDownstreams() - Method in class reactor.core.publisher.FluxProcessor: Return true if any Subscriber is actively subscribed
hasDownstreams() - Method in class reactor.core.publisher.MonoProcessor: Return true if any Subscriber is actively subscribed
hasDownstreams() - Method in class reactor.core.publisher.UnicastProcessor
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.
hasElement() - Method in class reactor.core.publisher.Mono: Emit a single boolean true if this Mono has an element.
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.DirectProcessor: Return true if terminated with onError
hasError() - Method in class reactor.core.publisher.Signal: Read whether this signal is on error and carries the cause.
hashCode() - Method in class reactor.core.publisher.Signal
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
hasValue() - Method in class 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.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.
Hooks.OperatorHook<T> - Class in reactor.core.publisher: Filtering and Handling options to apply on a given Publisher

I

ifFlux() - Method in class reactor.core.publisher.Hooks.OperatorHook: Apply hook only if Hooks.OperatorHook.publisher() is Flux
ifMono() - Method in class reactor.core.publisher.Hooks.OperatorHook: Apply hook only if Hooks.OperatorHook.publisher() is Mono
ifName(String...) - Method in class reactor.core.publisher.Hooks.OperatorHook: Apply hook only if one of the provided names matches the operator underlying type name (case insensitive, without Mono/Flux prefix or Fuseable suffix).
ifNameContains(String...) - Method in class reactor.core.publisher.Hooks.OperatorHook: Apply hook only if one of the provided names is contained in the operator's underlying type name (case insensitive, without Mono/Flux prefix or Fuseable suffix).
ifParallelFlux() - Method in class reactor.core.publisher.Hooks.OperatorHook: Apply hook only if Hooks.OperatorHook.publisher() is ParallelFlux
ignore() - Method in class reactor.core.publisher.Hooks.OperatorHook: Discard all Hooks.OperatorHook applied to the current Hooks.OperatorHook.publisher()
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 on the caller's thread immediately.
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.
inners() - Method in class reactor.core.publisher.DirectProcessor
inners() - Method in class reactor.core.publisher.EmitterProcessor
inners() - Method in class reactor.core.publisher.FluxProcessor
inners() - Method in class reactor.core.publisher.ReplayProcessor
inners() - Method in interface reactor.core.Scannable: Return a Stream of referenced inners (flatmap, multicast etc)
innerToString() - Method in class reactor.util.function.Tuple2: String representation that can be adjusted for higher-cardinality Tuples in order to show all values hold.
innerToString() - Method in class reactor.util.function.Tuple3
innerToString() - Method in class reactor.util.function.Tuple4
innerToString() - Method in class reactor.util.function.Tuple5
innerToString() - Method in class reactor.util.function.Tuple6
innerToString() - Method in class reactor.util.function.Tuple7
innerToString() - Method in class reactor.util.function.Tuple8
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, 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.
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.
isAlert(Throwable) - Static method in class reactor.util.concurrent.WaitStrategy: Test if exception is alert
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: Return whether has all subcribers cancelled and EmitterProcessor.create(boolean) auto shutdown argument been set to true.
isCancelled() - Method in interface reactor.core.publisher.FluxSink: Returns true if the downstream cancelled the sequence.
isCancelled() - Method in class reactor.core.publisher.MonoProcessor: Indicates whether this MonoProcessor has been interrupted via cancellation.
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 class 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: 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.MonoProcessor
isDisposed() - Method in class reactor.core.publisher.UnicastProcessor
isEmpty() - Method in class reactor.core.publisher.Operators.MonoSubscriber
isEmpty() - Method in class reactor.core.publisher.UnicastProcessor
isEmpty() - Method in class reactor.util.concurrent.OpenHashSet
isError() - Method in class reactor.core.publisher.MonoProcessor: Indicates whether this MonoProcessor has been completed with an error.
isError(Object) - Static method in class 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?
isInfoEnabled() - Method in interface reactor.util.Logger: Is the logger instance enabled for the INFO level?
isOnComplete() - Method in class reactor.core.publisher.Signal: Indicates whether this signal represents an onComplete event.
isOnError() - Method in class reactor.core.publisher.Signal: Indicates whether this signal represents an onError event.
isOnNext() - Method in class reactor.core.publisher.Signal: Indicates whether this signal represents an onNext event.
isOnSubscribe() - Method in class 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.QueueSupplier
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: Return true if this FluxProcessor supports multithread producing
isSuccess() - Method in class reactor.core.publisher.MonoProcessor: Indicates whether this MonoProcessor has been successfully completed a value.
isTerminated() - Method in class reactor.core.publisher.DirectProcessor
isTerminated() - Method in class reactor.core.publisher.EmitterProcessor
isTerminated() - Method in class reactor.core.publisher.FluxProcessor: Has this upstream finished or "completed" / "failed" ?
isTerminated() - Method in class reactor.core.publisher.MonoProcessor: 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
isTerminated() - Method in class reactor.core.publisher.UnicastProcessor
isTraceEnabled() - Method in interface reactor.util.Logger: Is the logger instance enabled for the TRACE level?
isWarnEnabled() - Method in interface reactor.util.Logger: Is the logger instance enabled for the WARN level?
iterator() - Method in interface reactor.core.Fuseable.QueueSubscription
iterator() - Method in class reactor.util.function.Tuple2

J

JdkFlowAdapter - Class in reactor.adapter: Convert a Java 9+ Flow.Publisher to/from a Reactive Streams Publisher.
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: Map values from two Publishers into time windows and emit combination of values in case their windows overlap.
just(T...) - Static method in class reactor.core.publisher.Flux: Create a Flux that emits the provided elements and then completes.
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.
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.
keys() - Method in class reactor.util.concurrent.OpenHashSet

L

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.
limitRate(int) - Method in class reactor.core.publisher.Flux: Ensure that backpressure signals from downstream subscribers are capped at the provided prefetchRate when propagated upstream, effectively rate limiting the upstream Publisher.
liteBlocking() - Static method in class reactor.util.concurrent.WaitStrategy: Variation of the WaitStrategy.blocking() that attempts to elide conditional wake-ups when the lock is uncontended.
log() - Method in class reactor.core.publisher.Flux: Observe all Reactive Streams signals and trace them using Logger support.
log(String) - Method in class reactor.core.publisher.Flux: Observe all Reactive Streams signals and trace them using Logger support.
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, 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, SignalType...) - Method in class reactor.core.publisher.Hooks.OperatorHook: Observe Reactive Streams signals matching the passed filter options and log them at INFO level.
log(String, boolean, SignalType...) - Method in class reactor.core.publisher.Hooks.OperatorHook: Observe Reactive Streams signals matching the passed filter options and log them at INFO level.
log(String, Level, SignalType...) - Method in class reactor.core.publisher.Hooks.OperatorHook: Observe Reactive Streams signals matching the passed filter optionsand log them at the provided level.
log(String, Level, boolean, SignalType...) - Method in class reactor.core.publisher.Hooks.OperatorHook: Observe Reactive Streams signals matching the passed filter options and log them at the provided level.
log() - Method in class reactor.core.publisher.Mono: Observe all Reactive Streams signals and trace them using Logger support.
log(String) - Method in class reactor.core.publisher.Mono: Observe all Reactive Streams signals and use Logger support to handle trace implementation.
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, 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() - 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.ParallelFlux: Observe all Reactive Streams signals 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, 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.
Logger - Interface in reactor.util: Logger interface designed for internal Reactor usage.
Loggers - Class in reactor.util: Expose static methods to get a logger depending on the environment (SLF4J or java.util.logging.Logger).

M

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.
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.
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.
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.
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(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.
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.
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.
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(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.
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.
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.
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.
Mono<T> - Class in reactor.core.publisher: A Reactive Streams Publisher with basic rx operators that completes successfully by emitting an element, or with an error.
Mono() - Constructor for class reactor.core.publisher.Mono
MonoProcessor<O> - Class in reactor.core.publisher: A MonoProcessor is a Mono extension that implements stateful semantics.
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).
MonoSource<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, e.g.
MonoSource(Publisher<? extends I>) - Constructor for class reactor.core.publisher.MonoSource: Build a MonoSource wrapper around the passed parent Publisher
MonoSubscriber(Subscriber<? super O>) - Constructor for class reactor.core.publisher.Operators.MonoSubscriber
multiplyCap(long, long) - Static method in class reactor.core.publisher.Operators: Cap a multiplication to Long.MAX_VALUE
MutableNextSignal<T> - Class in reactor.core.publisher: A Signal flavour that is dedicated to the ON_NEXT signal type and is mutable, allowing to minimize the number of Signal instances created.
mutate(T) - Method in class reactor.core.publisher.MutableNextSignal: Mutate this Signal instance with a new value as an alternative to creating a new instance.

N

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.
newElastic(int, ThreadFactory) - Method in interface reactor.core.scheduler.Schedulers.Factory: Scheduler that dynamically creates Workers resources and caches eventually, reusing them once the Workers have been shut down.
newElastic(String) - Static method in class reactor.core.scheduler.Schedulers: Scheduler that dynamically creates ExecutorService-based Workers and caches the thread pools, reusing them once the Workers have been shut down.
newElastic(String, int) - Static method in class reactor.core.scheduler.Schedulers: Scheduler that dynamically creates ExecutorService-based Workers and caches the thread pools, reusing them once the Workers have been shut down.
newElastic(String, int, boolean) - Static method in class reactor.core.scheduler.Schedulers: Scheduler that dynamically creates ExecutorService-based Workers and caches the thread pools, reusing them once the Workers have been shut down.
newElastic(int, ThreadFactory) - Static method in class reactor.core.scheduler.Schedulers: Scheduler that dynamically creates ExecutorService-based Workers and caches the thread pools, 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(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.
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.
newSingle(ThreadFactory) - Method in interface reactor.core.scheduler.Schedulers.Factory: Scheduler that hosts a single worker and is suited for non-blocking work.
newSingle(String) - Static method in class reactor.core.scheduler.Schedulers: Scheduler that hosts a single-threaded ExecutorService-based worker and is suited for parallel work.
newSingle(String, boolean) - Static method in class reactor.core.scheduler.Schedulers: Scheduler that hosts a single-threaded ExecutorService-based worker and is suited for parallel work.
newSingle(ThreadFactory) - Static method in class reactor.core.scheduler.Schedulers: Scheduler that hosts a single-threaded ExecutorService-based worker and is suited for parallel work.
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: Try emitting, might throw an unchecked exception.
next(T) - Static method in class 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.
NONE - Static variable in interface reactor.core.Fuseable: Indicates the QueueSubscription can't support the requested mode.
now(TimeUnit) - Method in interface reactor.core.scheduler.Scheduler: Returns the "current time" notion of this scheduler.
nullOrNegativeRequestException(long) - Static method in class reactor.core.Exceptions

O

of(T) - Static method in class reactor.core.publisher.MutableNextSignal: Create a new MutableNextSignal with an initial value.
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.
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(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(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(int) - 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(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.
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(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.
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.
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: Associates a disposable resource with this FluxSink that will be disposed in case the downstream cancels the sequence via Subscription.cancel().
onCancel(Disposable) - Method in interface reactor.core.publisher.MonoSink: Associates a disposable resource with this MonoSink that will be disposed on downstream.cancel().
onComplete() - Method in class reactor.core.publisher.BaseSubscriber
onComplete() - Method in class reactor.core.publisher.DirectProcessor
onComplete() - Method in class reactor.core.publisher.EmitterProcessor
onComplete() - Method in class reactor.core.publisher.MonoProcessor
onComplete() - Method in class reactor.core.publisher.Operators.MonoSubscriber
onComplete() - Method in class reactor.core.publisher.ReplayProcessor
onComplete() - Method in class reactor.core.publisher.UnicastProcessor
onDispose(Disposable) - Method in interface reactor.core.publisher.FluxSink: Associates a disposable resource with this FluxSink that will be disposed on the first terminate signal which may be a cancel, complete or error signal.
onDispose(Disposable) - Method in interface reactor.core.publisher.MonoSink: Associates a disposable resource with this MonoSink that will be disposed on the first terminate signal which may be a cancel, complete or error signal.
one() - Static method in class reactor.util.concurrent.QueueSupplier
onError(Throwable) - Method in class reactor.core.publisher.BaseSubscriber
onError(Throwable) - Method in class reactor.core.publisher.DirectProcessor
onError(Throwable) - Method in class reactor.core.publisher.EmitterProcessor
onError(Throwable) - Method in class reactor.core.publisher.MonoProcessor
onError(Throwable) - Method in class reactor.core.publisher.Operators.MonoSubscriber
onError(Throwable) - Method in class reactor.core.publisher.ReplayProcessor
onError(Throwable) - Method in class reactor.core.publisher.UnicastProcessor
onErrorDropped(Consumer<? super Throwable>) - Static method in class reactor.core.publisher.Hooks: Override global error dropped strategy which by default bubble back the error.
onErrorDropped(Throwable, Throwable) - Static method in class reactor.core.publisher.Operators: An unexpected exception is about to be dropped, and it additionally masks another one due to callback failure.
onErrorDropped(Throwable) - Static method in class reactor.core.publisher.Operators: An unexpected exception is about to be dropped.
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(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(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(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(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(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(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(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(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(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(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(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(T) - Method in class reactor.core.publisher.Flux: Simply emit a captured fallback value when any error is observed on this Flux.
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(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(T) - Method in class reactor.core.publisher.Mono: Simply emit a captured fallback value when any error is observed on this Mono.
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.Mono: Simply emit a captured fallback value when an error matching the given predicate is observed on this Mono.
onHandleError(BiConsumer<Thread, ? super Throwable>) - Static method in class reactor.core.scheduler.Schedulers: Define a hook that is executed when a Scheduler has handled an error.
onNext(T) - Method in class reactor.core.publisher.BaseSubscriber
onNext(T) - Method in class reactor.core.publisher.DirectProcessor
onNext(T) - Method in class reactor.core.publisher.EmitterProcessor
onNext(O) - Method in class reactor.core.publisher.MonoProcessor
onNext(I) - Method in class reactor.core.publisher.Operators.MonoSubscriber
onNext(T) - Method in class reactor.core.publisher.ReplayProcessor
onNext(T) - Method in class reactor.core.publisher.UnicastProcessor
onNextDropped(Consumer<Object>) - Static method in class reactor.core.publisher.Hooks: Override global data dropped strategy which by default throw Exceptions.failWithCancel()
onNextDropped(T) - Static method in class reactor.core.publisher.Operators: An unexpected event is about to be dropped.
onOperator(Function<? super Hooks.OperatorHook<T>, ? extends Hooks.OperatorHook<T>>) - Static method in class reactor.core.publisher.Hooks: Configure a global chain of "assembly" hooks to intercept signals produced by the passed Publisher (Flux or Mono).
onOperatorError(BiFunction<? super Throwable, Object, ? extends Throwable>) - Static method in class reactor.core.publisher.Hooks: Override global operator error mapping which by default add as suppressed exception either data driven exception or error driven exception.
onOperatorError(Throwable) - Static method in class reactor.core.publisher.Operators: Map an "operator" error.
onOperatorError(Subscription, Throwable) - Static method in class reactor.core.publisher.Operators: Map an "operator" error given an operator parent Subscription.
onOperatorError(Subscription, Throwable, Object) - Static method in class reactor.core.publisher.Operators: Map an "operator" error given an operator parent Subscription.
onRejectedExecution() - Static method in class reactor.core.publisher.Operators: Return a wrapped RejectedExecutionException which can be thrown by the operator.
onRejectedExecution(Subscription, Throwable, Object) - 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.
onSubscribe(Subscription) - Method in class reactor.core.publisher.BaseSubscriber
onSubscribe(Subscription) - Method in class reactor.core.publisher.DirectProcessor
onSubscribe(Subscription) - Method in class reactor.core.publisher.EmitterProcessor
onSubscribe(Subscription) - Method in class reactor.core.publisher.MonoProcessor
onSubscribe(Subscription) - Method in class reactor.core.publisher.Operators.MonoSubscriber
onSubscribe(Subscription) - Method in class reactor.core.publisher.ReplayProcessor
onSubscribe(Subscription) - Method in class reactor.core.publisher.UnicastProcessor
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.
OpenHashSet<T> - Class in reactor.util.concurrent: A simple open hash set with add, remove and clear capabilities only.
OpenHashSet() - Constructor for class reactor.util.concurrent.OpenHashSet
OpenHashSet(int, float) - Constructor for class reactor.util.concurrent.OpenHashSet
Operators - Class in reactor.core.publisher: An 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.
operatorStacktrace() - Method in class reactor.core.publisher.Hooks.OperatorHook: Enable operator stack recorder that captures a declaration stack whenever an operator is instantiated.
or(Mono<? extends T>) - Method in class reactor.core.publisher.Mono: Emit the first available result from this mono or the other mono.

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(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.
parallel() - 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.
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.
parents() - Method in interface reactor.core.Scannable: Return a Stream navigating the Subscription chain (upward).
parking() - Static method in class reactor.util.concurrent.WaitStrategy: Parking strategy that initially spins, then uses a Thread.yield(), and eventually sleep (LockSupport.parkNanos(1)) for the minimum number of nanos the OS and JVM will allow while the consumers are waiting on a barrier.
parking(int) - Static method in class reactor.util.concurrent.WaitStrategy: Parking strategy that initially spins, then uses a Thread.yield(), and eventually sleep (LockSupport.parkNanos(1)) for the minimum number of nanos the OS and JVM will allow while the consumers are waiting on a barrier.
peek() - Method in interface reactor.core.Fuseable.QueueSubscription
peek() - Method in class reactor.core.publisher.MonoProcessor: Returns the value that completed this MonoProcessor.
phasedOff(long, long, TimeUnit, WaitStrategy) - Static method in class reactor.util.concurrent.WaitStrategy: Phased wait strategy for waiting consumers on a barrier.
phasedOffLiteLock(long, long, TimeUnit) - Static method in class reactor.util.concurrent.WaitStrategy: Block with wait/notifyAll semantics
phasedOffLock(long, long, TimeUnit) - Static method in class reactor.util.concurrent.WaitStrategy: Block with wait/notifyAll semantics
phasedOffSleep(long, long, TimeUnit) - Static method in class reactor.util.concurrent.WaitStrategy: Block by parking in a loop
poll() - Method in class reactor.core.publisher.Operators.MonoSubscriber
poll() - Method in class reactor.core.publisher.UnicastProcessor
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.
publisher() - Method in class reactor.core.publisher.Hooks.OperatorHook: The publisher being decorated
publisherToFlowPublisher(Publisher<T>) - Static method in class reactor.adapter.JdkFlowAdapter: Return a Flux from a java Flow.Publisher
publishNext() - Method in class reactor.core.publisher.Flux: Prepare a Mono which shares this Flux sequence and dispatches the first observed item to subscribers in a backpressure-aware manner.
publishOn(Scheduler) - Method in class reactor.core.publisher.Flux: Run onNext, onComplete and onError on a supplied Scheduler Worker.
publishOn(Scheduler, int) - Method in class reactor.core.publisher.Flux: Run onNext, onComplete and onError on a supplied Scheduler 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) - Method in class reactor.core.publisher.Mono: Run onNext, onComplete and onError on a supplied 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.

Q

QueueSupplier<T> - Class in reactor.util.concurrent: Provide a 1-producer/1-consumer ready queue adapted for a given capacity.

R

range(int, int) - Static method in class reactor.core.publisher.Flux: Build a Flux that will only emit a sequence of incrementing integer from start to start + count then complete.
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.publisher - package reactor.core.publisher: Provide for Flux, Mono composition API and Processor implementations
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.concurrent - package reactor.util.concurrent: Queue suppliers and busy spin utils WaitStrategy.
reactor.util.function - package reactor.util.function: Tuples provide a type-safe way to specify multiple parameters.
reduce(BiFunction<T, T, T>) - Method in class reactor.core.publisher.Flux: Reduce the values from this Flux sequence into an single object of the same type than the emitted items.
reduce(A, BiFunction<A, ? super T, A>) - Method in class reactor.core.publisher.Flux: Reduce the values from this Flux sequence into an single object matching the type of a seed value.
reduce(BiFunction<T, T, T>) - Method in class reactor.core.publisher.ParallelFlux: Reduces all values within a 'rail' and across 'rails' with a reducer function into a single sequential value.
reduce(Supplier<R>, BiFunction<R, ? super T, R>) - Method in class reactor.core.publisher.ParallelFlux: Reduces all values within a 'rail' to a single value (with a possibly different type) via a reducer function that is initialized on each rail from an initialSupplier value.
reduceWith(Supplier<A>, BiFunction<A, ? super T, A>) - Method in class reactor.core.publisher.Flux: Reduce the values from this Flux sequence into an 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.
REJECTED - Static variable in interface reactor.core.scheduler.Scheduler: Returned by the schedule() methods if the Scheduler or the Worker has ben shut down, or is incapable of scheduling tasks with a delay/periodically (not "time capable").
remove() - Method in interface reactor.core.Fuseable.QueueSubscription
remove(Object) - Method in interface reactor.core.Fuseable.QueueSubscription
remove(T) - Method in class reactor.util.concurrent.OpenHashSet
removeAll(Collection<?>) - Method in interface reactor.core.Fuseable.QueueSubscription
repeat() - Method in class reactor.core.publisher.Flux: Repeatedly and indefinitely subscribe to the source upon completion of the previous subscription.
repeat(BooleanSupplier) - Method in class reactor.core.publisher.Flux: Repeatedly subscribe to the source if the predicate returns true after completion of the previous subscription.
repeat(long) - Method in class reactor.core.publisher.Flux: Repeatedly subscribe to the source numRepeat times.
repeat(long, BooleanSupplier) - Method in class reactor.core.publisher.Flux: Repeatedly subscribe to the source if the predicate returns true after completion of the previous subscription.
repeat() - Method in class reactor.core.publisher.Mono: Repeatedly and indefinitely subscribe to the source upon completion of the previous subscription.
repeat(BooleanSupplier) - Method in class reactor.core.publisher.Mono: Repeatedly subscribe to the source if the predicate returns true after completion of the previous subscription.
repeat(long) - Method in class reactor.core.publisher.Mono: Repeatedly subscribe to the source numRepeat times.
repeat(long, BooleanSupplier) - Method in class reactor.core.publisher.Mono: Repeatedly subscribe to the source if the predicate returns true after completion of the previous subscription.
repeatWhen(Function<Flux<Long>, ? extends Publisher<?>>) - Method in class reactor.core.publisher.Flux: Repeatedly subscribe to this Flux when a companion sequence emits elements in response to the flux completion signal.
repeatWhen(Function<Flux<Long>, ? extends Publisher<?>>) - Method in class reactor.core.publisher.Mono: Repeatedly subscribe to this Mono when a companion sequence emits elements in response to the flux completion signal.
repeatWhenEmpty(Function<Flux<Long>, ? extends Publisher<?>>) - Method in class reactor.core.publisher.Mono: Repeatedly subscribe to this Mono as long as the current subscription to this Mono completes empty and the companion Publisher produces an onNext signal.
repeatWhenEmpty(int, Function<Flux<Long>, ? extends Publisher<?>>) - Method in class reactor.core.publisher.Mono: Repeatedly subscribe to this Mono as long as the current subscription to this Mono completes empty and the companion Publisher produces an onNext signal.
replace(AtomicReferenceFieldUpdater<F, Subscription>, F, Subscription) - Static method in class reactor.core.publisher.Operators: A generic utility to atomically replace a subscription or cancel the replacement if the current subscription is marked as already cancelled (as in Operators.cancelledSubscription()).
replay() - Method in class reactor.core.publisher.Flux: Turn this Flux into a hot source and cache last emitted signals for further Subscriber.
replay(int) - Method in class reactor.core.publisher.Flux: Turn this Flux into a connectable hot source and cache last emitted signals for further Subscriber.
replay(Duration) - Method in class reactor.core.publisher.Flux: Turn this Flux into a connectable hot source and cache last emitted signals for further Subscriber.
replay(int, Duration) - Method in class reactor.core.publisher.Flux: Turn this Flux into a connectable hot source and cache last emitted signals for further Subscriber.
replay(Duration, Scheduler) - Method in class reactor.core.publisher.Flux: Turn this Flux into a connectable hot source and cache last emitted signals for further Subscriber.
replay(int, Duration, Scheduler) - Method in class reactor.core.publisher.Flux: Turn this Flux into a connectable hot source and cache last emitted signals for further Subscriber.
ReplayProcessor<T> - Class in reactor.core.publisher: Replays all or the last N items to Subscribers.
reportBadRequest(long) - Static method in class reactor.core.publisher.Operators: Throw an IllegalArgumentException if the request is null or negative.
reportMoreProduced() - Static method in class reactor.core.publisher.Operators: Throw 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.
request(long) - Method in class reactor.core.publisher.BaseSubscriber
request(long) - Method in class reactor.core.publisher.MonoProcessor
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
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
requestTask(Subscription) - Method in class reactor.core.publisher.TopicProcessor
requestTask(Subscription) - Method in class reactor.core.publisher.WorkQueueProcessor
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
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.
resetOnNextDropped() - Static method in class reactor.core.publisher.Hooks: Reset global data dropped strategy to throwing via Exceptions.failWithCancel()
resetOnOperator() - Static method in class reactor.core.publisher.Hooks: Reset global "assembly" hook tracking
resetOnOperatorError() - Static method in class reactor.core.publisher.Hooks: Reset global operator error mapping to adding as suppressed exception.
retainAll(Collection<?>) - Method in interface reactor.core.Fuseable.QueueSubscription
retry() - Method in class reactor.core.publisher.Flux: Re-subscribes to this Flux sequence if it signals any error, indefinitely.
retry(long) - Method in class reactor.core.publisher.Flux: Re-subscribes to this Flux sequence if it signals any error, for a fixed number of times.
retry(Predicate<? super Throwable>) - Method in class reactor.core.publisher.Flux: Re-subscribes to this Flux sequence if it signals any error that matches the given Predicate, otherwise push the error downstream.
retry(long, Predicate<? super Throwable>) - Method in class reactor.core.publisher.Flux: Re-subscribes to this Flux sequence up to the specified number of retries if it signals any error that match the given Predicate, otherwise push the error downstream.
retry() - Method in class reactor.core.publisher.Mono: Re-subscribes to this Mono sequence if it signals any error, indefinitely.
retry(long) - Method in class reactor.core.publisher.Mono: Re-subscribes to this Mono sequence if it signals any error, for a fixed number of times.
retry(Predicate<? super Throwable>) - Method in class reactor.core.publisher.Mono: Re-subscribes to this Mono sequence if it signals any error that matches the given Predicate, otherwise push the error downstream.
retry(long, Predicate<? super Throwable>) - Method in class reactor.core.publisher.Mono: Re-subscribes to this Mono sequence up to the specified number of retries if it signals any error that match the given Predicate, otherwise push the error downstream.
retryWhen(Function<Flux<Throwable>, ? extends Publisher<?>>) - Method in class reactor.core.publisher.Flux: Retries this Flux when a companion sequence signals an item in response to this Flux error signal
retryWhen(Function<Flux<Throwable>, ? extends Publisher<?>>) - Method in class reactor.core.publisher.Mono: Retries this Mono when a companion sequence signals an item in response to this Mono error signal
run() - Method in class reactor.core.publisher.TopicProcessor
run() - Method in class reactor.core.publisher.WorkQueueProcessor
runOn(Scheduler) - Method in class reactor.core.publisher.ParallelFlux: Specifies where each 'rail' will observe its incoming values with no 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 possibly 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(Subscriber<? 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.
scan(Scannable.Attr) - Method in class reactor.core.publisher.EmitterProcessor
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(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(Scannable.Attr) - Method in class reactor.core.publisher.FluxProcessor
scan(Scannable.Attr) - Method in class reactor.core.publisher.FluxSource
scan(Scannable.Attr) - Method in class reactor.core.publisher.MonoProcessor
scan(Scannable.Attr) - Method in class reactor.core.publisher.MonoSource
scan(Scannable.Attr) - Method in class reactor.core.publisher.Operators.DeferredSubscription
scan(Scannable.Attr) - Method in class reactor.core.publisher.Operators.MonoSubscriber
scan(Scannable.Attr) - Method in class reactor.core.publisher.ReplayProcessor
scan(Scannable.Attr) - Method in interface reactor.core.Scannable: Introspect a component's specific state attribute, returning a best effort value or null if the attribute doesn't make sense for that particular component.
scan(Scannable.Attr, Class<T>) - Method in interface reactor.core.Scannable: Introspect a component's specific state attribute, returning a best effort value casted to the provided class, or null if the attribute doesn't make sense for that particular component.
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 - Enum in reactor.core: A list of reserved keys for component state scanning
scanOrDefault(Scannable.Attr, T) - Method in interface reactor.core.Scannable: Introspect a component's specific state attribute, returning a best effort casted value or the provided default if the attribute doesn't make sense for that particular component.
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, long, TimeUnit) - Method in interface reactor.core.scheduler.Scheduler: Schedules the execution of the given task with the given delay amount.
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.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 - 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 in a FIFO order, guaranteed non-concurrently with respect to each other.
Schedulers - Class in reactor.core.scheduler: Schedulers provides various Scheduler factories useable 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
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: Create a FluxProcessor that safely gates multi-threaded producer Subscriber.onNext(Object).
serialize(Subscriber<? super T>) - Static method in class reactor.core.publisher.Operators: Safely gate a Subscriber by making sure onNext signals are delivered sequentially (serialized).
set(Subscription) - Method in class reactor.core.publisher.Operators.DeferredSubscription: Atomically sets the single subscription and requests the missed amount from it.
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.
setFactory(Schedulers.Factory) - Static method in class reactor.core.scheduler.Schedulers: Replace Schedulers factories (newParallel, newSingle and newElastic).
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(boolean) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using QueueSupplier.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and the passed auto-cancel setting.
share(ExecutorService) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using QueueSupplier.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and auto-cancel.
share(ExecutorService, boolean) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using QueueSupplier.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and the passed auto-cancel setting.
share(String, int) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using QueueSupplier.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and the passed auto-cancel setting.
share(String, int, boolean) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using the blockingWait Strategy, passed backlog size, and auto-cancel settings.
share(ExecutorService, int) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using passed backlog size, blockingWait Strategy and will auto-cancel.
share(ExecutorService, int, boolean) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using passed backlog size, blockingWait Strategy and the auto-cancel argument.
share(String, int, WaitStrategy) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using passed backlog size, wait strategy and will auto-cancel.
share(String, int, Supplier<E>) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using passed backlog size, wait strategy and signal supplier.
share(String, int, WaitStrategy, Supplier<E>) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using passed backlog size, wait strategy and signal supplier.
share(String, int, WaitStrategy, boolean) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using passed backlog size, wait strategy and auto-cancel settings.
share(ExecutorService, int, WaitStrategy) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using passed backlog size, wait strategy and will auto-cancel.
share(ExecutorService, int, WaitStrategy, boolean) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using passed backlog size, wait strategy and auto-cancel settings.
share(ExecutorService, ExecutorService, int, WaitStrategy, boolean) - Static method in class reactor.core.publisher.TopicProcessor: Create a new TopicProcessor using passed backlog size, wait strategy and auto-cancel settings.
share(boolean) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new WorkQueueProcessor using QueueSupplier.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and the passed auto-cancel setting.
share(ExecutorService) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new WorkQueueProcessor using QueueSupplier.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and auto-cancel.
share(ExecutorService, boolean) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new WorkQueueProcessor using QueueSupplier.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and the passed auto-cancel setting.
share(String, int) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new TopicProcessor using the passed buffer size, blockingWait Strategy and auto-cancel.
share(String, int, boolean) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new TopicProcessor using the passed buffer size, blockingWait Strategy and the passed auto-cancel setting.
share(ExecutorService, int) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new TopicProcessor using the passed buffer size, blockingWait Strategy and auto-cancel.
share(ExecutorService, int, boolean) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new WorkQueueProcessor using the passed buffer size, blockingWait Strategy and auto-cancel.
share(String, int, WaitStrategy) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new WorkQueueProcessor using the passed buffer size, blockingWait Strategy and auto-cancel.
share(String, int, WaitStrategy, boolean) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new WorkQueueProcessor using the passed buffer size, blockingWait Strategy and auto-cancel settings.
share(ExecutorService, int, WaitStrategy) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new WorkQueueProcessor using the passed buffer size and blockingWait Strategy settings but will auto-cancel.
share(ExecutorService, int, WaitStrategy, boolean) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new WorkQueueProcessor using the passed buffer size, wait strategy and auto-cancel settings.
share(ExecutorService, ExecutorService, int, WaitStrategy, boolean) - Static method in class reactor.core.publisher.WorkQueueProcessor: Create a new WorkQueueProcessor using the passed buffer size, wait strategy and auto-cancel settings.
shutdownNow() - Static method in class reactor.core.scheduler.Schedulers: Clear any cached Scheduler and call dispose on them.
Signal<T> - Class in reactor.core.publisher: A domain representation of a Reactive Stream signal.
Signal() - Constructor for class reactor.core.publisher.Signal
signalAllWhenBlocking() - Method in class reactor.util.concurrent.WaitStrategy: Implementations should signal the waiting consumers that the cursor has advanced.
SignalType - Enum in reactor.core.publisher: Reactive Stream signal types
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(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.
single() - Static method in class reactor.core.scheduler.Schedulers: Scheduler that hosts a single-threaded ExecutorService-based worker and is suited for parallel work.
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.
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: Create a FluxSink that safely gates multi-threaded producer Subscriber.onNext(Object).
sink(FluxSink.OverflowStrategy) - Method in class reactor.core.publisher.FluxProcessor: Create a FluxSink that safely gates multi-threaded producer Subscriber.onNext(Object).
size() - Method in class reactor.core.publisher.Operators.MonoSubscriber
size() - Method in class reactor.core.publisher.UnicastProcessor
size() - Method in class reactor.util.concurrent.OpenHashSet
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.
sleeping() - Static method in class reactor.util.concurrent.WaitStrategy: Yielding strategy that uses a Thread.sleep(1) for consumers waiting on a barrier after an initially spinning.
small() - Static method in class reactor.util.concurrent.QueueSupplier
SMALL_BUFFER_SIZE - Static variable in class reactor.util.concurrent.QueueSupplier: 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.FluxSource
source - Variable in class reactor.core.publisher.MonoSource
specificShutdown() - Method in class reactor.core.publisher.TopicProcessor
specificShutdown() - Method in class reactor.core.publisher.WorkQueueProcessor
start() - Method in interface reactor.core.scheduler.Scheduler: Instructs this Scheduler to prepare itself for running tasks directly or through its Workers.
startWith(Iterable<? extends T>) - Method in class reactor.core.publisher.Flux: Prepend the given Iterable before this Flux sequence.
startWith(T...) - Method in class reactor.core.publisher.Flux: Prepend the given values before this Flux sequence.
startWith(Publisher<? extends T>) - Method in class reactor.core.publisher.Flux: Prepend the given Publisher sequence to this Flux sequence.
subOrZero(long, long) - Static method in class reactor.core.publisher.Operators: Cap a subtraction to 0
subscribe(Subscriber<? super T>) - Method in class reactor.core.publisher.DirectProcessor
subscribe(Subscriber<? super T>) - Method in class reactor.core.publisher.EmitterProcessor
subscribe() - Method in class reactor.core.publisher.Flux: Subscribe to this Flux and request unbounded demand.
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>, 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>, 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, Consumer<? super Subscription>) - Method in class reactor.core.publisher.Flux: Subscribe Consumer to this Flux that will respectively consume all the elements in the sequence, handle errors, react to completion, and request upon subscription.
subscribe(Subscriber<? super OUT>) - Method in class reactor.core.publisher.FluxProcessor: Note: From 3.1 this is to be left unimplemented
subscribe(Subscriber<? super O>) - Method in class reactor.core.publisher.FluxSource: Default is simply delegating and decorating with Flux API.
subscribe() - Method in class reactor.core.publisher.Mono: Subscribe to this Mono and request unbounded demand, then represent the subscription as a MonoProcessor (allowing to block, cancel as well as many other operations).
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>, 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>, 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, 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(Subscriber<? super O>) - Method in class reactor.core.publisher.MonoProcessor
subscribe(Subscriber<? super O>) - Method in class reactor.core.publisher.MonoSource: Default is simply delegating and decorating with Mono API.
subscribe(Subscriber<? 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() - Method in class reactor.core.publisher.ParallelFlux: Subscribes to this ParallelFlux and triggers the execution chain for all 'rails'.
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(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>, 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.ParallelFlux: Subscribes to this ParallelFlux by providing an onNext, onError, onComplete and onSubscribe callback and triggers the execution chain for all 'rails'.
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(Subscriber<? super T>) - Method in class reactor.core.publisher.ReplayProcessor
subscribe(Subscription) - Static method in class reactor.core.publisher.Signal: Creates and returns a Signal of variety Type.ON_SUBSCRIBE.
subscribe(Subscriber<? super E>) - Method in class reactor.core.publisher.TopicProcessor
subscribe(Subscriber<? super T>) - Method in class reactor.core.publisher.UnicastProcessor
subscribe(Subscriber<? super E>) - Method in class reactor.core.publisher.WorkQueueProcessor
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.
subscribeWith(E) - Method in class reactor.core.publisher.Flux: Subscribe the given Subscriber to this Flux and return said Subscriber (eg.
subscribeWith(E) - Method in class reactor.core.publisher.Mono: Subscribe the given Subscriber to this Mono and return said Subscriber (eg.
success() - Method in interface reactor.core.publisher.MonoSink: Complete without any value.
success(T) - Method in interface reactor.core.publisher.MonoSink: Complete with the given value.
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: Switch to a new Publisher generated via a Function whenever this Flux produces an item.
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 in the source.
switchOnNext(Publisher<? extends Publisher<? extends T>>, int) - 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 in the source.
switchOnNext() - Static method in class reactor.core.publisher.FluxProcessor: Build a FluxProcessor whose data are emitted by the most recent emitted Publisher.
SYNC - Static variable in interface reactor.core.Fuseable: Indicates the QueueSubscription can perform sync-fusion.
SynchronousSink<T> - Interface in reactor.core.publisher: Interface to generate signals to a bridged Subscriber.

T

take(long) - 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, Scheduler) - Method in class reactor.core.publisher.Flux: Relay values from this Flux until the specified Duration elapses, as measured on the specified Scheduler.
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.
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).
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.
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().
TERMINATED - Static variable in class reactor.core.Exceptions: A singleton instance of a Throwable indicating a terminal state for exceptions, don't leak this!
then() - Method in class reactor.core.publisher.Flux: Return a Mono<Void> that completes when this Flux completes.
then(Mono<V>) - Method in class reactor.core.publisher.Flux: Let this Flux complete then play signals from a provided Mono.
then() - Method in class reactor.core.publisher.Mono: Return a Mono<Void> which only replays complete and error signals from this 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 then play another Publisher.
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.
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, 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, 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, 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(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, 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(Duration) - Method in class reactor.core.publisher.Mono: Propagate a TimeoutException in case no item arrives within the given Duration.
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.Mono: Signal a TimeoutException error in case an item doesn't arrive before the given period, as measured on the provided 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(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, 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.
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(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() - 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(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(T1[]) - Method in interface reactor.core.Fuseable.QueueSubscription
toArray() - Method in class reactor.util.function.Tuple2: Turn this Tuples into a plain Object array.
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
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(long) - Method in class reactor.core.publisher.Flux: Transform this Flux into a lazy Iterable blocking on Iterator.next() calls.
toIterable(long, 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 Tuples into a plain Object list.
TopicProcessor<E> - Class in reactor.core.publisher: An implementation of a RingBuffer backed message-passing Processor implementing publish-subscribe with async event loops.
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.FluxSource
toString() - Method in class reactor.core.publisher.Mono
toString() - Method in class reactor.core.publisher.MonoSource
toString() - Method in class reactor.core.publisher.Signal
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.
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.
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 values
Tuple3<T1,T2,T3> - Class in reactor.util.function: A tuple that holds three values
Tuple4<T1,T2,T3,T4> - Class in reactor.util.function: A tuple that holds four values
Tuple5<T1,T2,T3,T4,T5> - Class in reactor.util.function: A tuple that holds five 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 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.QueueSupplier
unbounded(int) - Static method in class reactor.util.concurrent.QueueSupplier: Returns an unbounded, linked-array-based Queue.
undefined() - Static method in class reactor.core.publisher.MutableNextSignal: Create a new MutableNextSignal that hasn't had a value set yet.
UnicastProcessor<T> - Class in reactor.core.publisher: A Processor implementation that takes a custom queue and allows only a single subscriber.
UnicastProcessor(Queue<T>) - Constructor for class reactor.core.publisher.UnicastProcessor
UnicastProcessor(Queue<T>, Disposable) - Constructor for class reactor.core.publisher.UnicastProcessor
UnicastProcessor(Queue<T>, Consumer<? super T>, Disposable) - Constructor for class reactor.core.publisher.UnicastProcessor
untilOther(Publisher<?>) - Method in class reactor.core.publisher.Mono: Subscribe to this Mono and another Publisher, which will be used as a trigger for the emission of this Mono's element.
untilOtherDelayError(Publisher<?>) - Method in class reactor.core.publisher.Mono: Subscribe to this Mono and another Publisher, which will be used as a trigger for the emission of this Mono's element.
unwrap(Throwable) - Static method in class reactor.core.Exceptions: Unwrap a particular Throwable only if it is was wrapped via bubble or propagate.
upstream() - Method in class reactor.core.publisher.BaseSubscriber: Return current Subscription
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>>, 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.
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.

V

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(long) - Static method in class reactor.core.publisher.Operators: Evaluate if a request is strictly positive otherwise Operators.reportBadRequest(long)
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.
value - Variable in class reactor.core.publisher.Operators.MonoSubscriber
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.Scannable.Attr: 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.Scannable.Attr: Returns an array containing the constants of this enum type, in the order they are declared.

W

waitFor(long, LongSupplier, Runnable) - Method in class reactor.util.concurrent.WaitStrategy: Wait for the given sequence to be available.
WaitStrategy - Class in reactor.util.concurrent: Strategy employed to wait for specific LongSupplier values with various spinning strategies.
WaitStrategy() - Constructor for class reactor.util.concurrent.WaitStrategy
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.
when(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 been fulfilled, aggregating their values into a Tuple2.
when(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 been fulfilled, aggregating their values as defined by the combinator function.
when(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 been fulfilled, aggregating their values into a Tuple3.
when(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 been fulfilled, aggregating their values into a Tuple4.
when(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 been fulfilled, aggregating their values into a Tuple5.
when(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 been fulfilled, aggregating their values into a Tuple6.
when(Iterable<? extends Publisher<Void>>) - Static method in class reactor.core.publisher.Mono: Aggregate given void publishers into a new Mono that will be fulfilled when all of the given Publishers have been fulfilled.
when(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 been fulfilled, aggregating their values according to the provided combinator function.
when(Publisher<Void>...) - Static method in class reactor.core.publisher.Mono: Aggregate given void publishers into a new Mono that will be fulfilled when all of the given sources have been fulfilled.
when(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 been fulfilled, aggregating their values according to the provided combinator function.
whenDelayError(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 been fulfilled, aggregating their values into a Tuple2 and delaying errors.
whenDelayError(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 been fulfilled, aggregating their values into a Tuple3 and delaying errors.
whenDelayError(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 been fulfilled, aggregating their values into a Tuple4 and delaying errors.
whenDelayError(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 been fulfilled, aggregating their values into a Tuple5 and delaying errors.
whenDelayError(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 been fulfilled, aggregating their values into a Tuple6 and delaying errors.
whenDelayError(Iterable<? extends Publisher<Void>>) - Static method in class reactor.core.publisher.Mono: Aggregate given void publishers into a new Mono that will be fulfilled when all of the given sources have been fulfilled.
whenDelayError(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 been fulfilled.
whenDelayError(Publisher<Void>...) - Static method in class reactor.core.publisher.Mono: Merge given void publishers into a new Mono that will be fulfilled when all of the given sources have been fulfilled.
whenDelayError(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 been fulfilled, aggregating their values according to the provided combinator function and delaying errors.
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(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
window(Duration) - Method in class reactor.core.publisher.Flux: Split this Flux sequence into continuous, non-overlapping windows that open for a timespan 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 timespan 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 timespan Duration (as measured on the provided Scheduler).
window(Duration, Duration, Scheduler) - Method in class reactor.core.publisher.Flux: Split this Flux sequence into multiple Flux windows that open for a given timespan Duration, after which it closes with onComplete.
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, 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.
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.
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.
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.
WorkQueueProcessor<E> - Class in reactor.core.publisher: An implementation of a RingBuffer backed message-passing Processor implementing work-queue distribution with async event loops.
wrap(Subscriber<IN>, Publisher<OUT>) - Static method in class reactor.core.publisher.FluxProcessor: Transform a receiving Subscriber and a producing Publisher in a logical FluxProcessor.
wrap(Publisher<? extends I>) - Static method in class reactor.core.publisher.FluxSource: Unchecked wrap of Publisher as Flux, supporting Fuseable sources
wrap(Publisher<? extends I>) - Static method in class reactor.core.publisher.MonoSource: Unchecked wrap of Publisher as Mono, supporting Fuseable sources

X

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

Y

yielding() - Static method in class reactor.util.concurrent.WaitStrategy: Yielding strategy that uses a Thread.yield() for consumers waiting on a barrier after an initially spinning.

Z

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>) - 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>, 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(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 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(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 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(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(Function<? super Object[], ? extends V>, Mono<? extends T>...) - Static method in class reactor.core.publisher.Mono: Zip the values from given monos together using a combinator function, producing a new Mono that will be fulfilled when all of the given Monos have been fulfilled.
zip(Function<? super Object[], ? extends V>, Iterable<? extends Mono<? extends T>>) - Static method in class reactor.core.publisher.Mono: Zip the values from given monos together using a combinator function, producing a new Mono that will be fulfilled when all of the given Monos have been fulfilled.
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>, 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>, 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>, 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.
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 Y Z