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

W

warn(String) - Method in class reactor.test.util.TestLogger

warn(String, Object...) - Method in class reactor.test.util.TestLogger

warn(String, Throwable) - Method in class reactor.test.util.TestLogger

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

Log a message at the WARN level.

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

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

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

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

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

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

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

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

wasCancelled() - Method in class reactor.test.publisher.PublisherProbe.DefaultPublisherProbe

wasCancelled() - Method in interface reactor.test.publisher.PublisherProbe

wasRequested() - Method in class reactor.test.publisher.PublisherProbe.DefaultPublisherProbe

wasRequested() - Method in interface reactor.test.publisher.PublisherProbe

wasSubscribed() - Method in class reactor.test.publisher.PublisherProbe.DefaultPublisherProbe

wasSubscribed() - Method in interface reactor.test.publisher.PublisherProbe

when(Publisher<?>...) - Static method in class reactor.core.publisher.Mono

Aggregate given publishers into a new Mono that will be fulfilled when all of the given sources have completed.

when(Iterable<? extends Publisher<?>>) - Static method in class reactor.core.publisher.Mono

Aggregate given publishers into a new Mono that will be fulfilled when all of the given Publishers have completed.

whenDelayError(Iterable<? extends Publisher<?>>) - Static method in class reactor.core.publisher.Mono

Aggregate given publishers into a new Mono that will be fulfilled when all of the given sources have completed.

whenDelayError(Publisher<?>...) - Static method in class reactor.core.publisher.Mono

Merge given publishers into a new Mono that will be fulfilled when all of the given sources have completed.

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

Split this Flux sequence into multiple Flux windows containing maxSize elements (or less for the final window) and starting from the first item.

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

Split this Flux sequence into multiple Flux windows of size maxSize, that each open every skip elements in the source.

window(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 windowingTimespan Duration (as measured on the parallel Scheduler).

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

Split this Flux sequence into multiple Flux windows that open for a given windowingTimespan Duration, after which it closes with onComplete.

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

Split this Flux sequence into continuous, non-overlapping windows that open for a windowingTimespan Duration (as measured on the provided Scheduler).

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

Split this Flux sequence into multiple Flux windows that open for a given windowingTimespan Duration, after which it closes with onComplete.

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

Split this Flux sequence into multiple Flux windows containing maxSize elements (or less for the final window) and starting from the first item.

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

Split this Flux sequence into multiple Flux windows containing maxSize elements (or less for the final window) and starting from the first item.

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

Split this Flux sequence into multiple Flux windows containing maxSize elements (or less for the final window) and starting from the first item.

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

Split this Flux sequence into multiple Flux windows containing maxSize elements (or less for the final window) and starting from the first item.

windowUntil(Predicate<T>) - Method in class reactor.core.publisher.Flux

Split this Flux sequence into multiple Flux windows delimited by the given predicate.

windowUntil(Predicate<T>, boolean) - Method in class reactor.core.publisher.Flux

Split this Flux sequence into multiple Flux windows delimited by the given predicate.

windowUntil(Predicate<T>, boolean, int) - Method in class reactor.core.publisher.Flux

Split this Flux sequence into multiple Flux windows delimited by the given predicate and using a prefetch.

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

Collect subsequent repetitions of an element (that is, if they arrive right after one another) into multiple Flux windows.

windowUntilChanged(Function<? super T, ? super V>) - Method in class reactor.core.publisher.Flux

Collect subsequent repetitions of an element (that is, if they arrive right after one another), as compared by a key extracted through the user provided Function, into multiple Flux windows.

windowUntilChanged(Function<? super T, ? extends V>, BiPredicate<? super V, ? super V>) - Method in class reactor.core.publisher.Flux

Collect subsequent repetitions of an element (that is, if they arrive right after one another), as compared by a key extracted through the user provided Function and compared using a supplied BiPredicate, into multiple Flux windows.

windowWhen(Publisher<U>, 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.

withInitialContext(Context) - Method in class reactor.test.StepVerifierOptions

Set an initial Context to be propagated by the StepVerifier when it subscribes to the sequence under test.

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.

withRetryContext(ContextView) - Method in class reactor.util.retry.RetryBackoffSpec

Set the user provided context that can be used to manipulate state on retries.

withRetryContext(ContextView) - Method in class reactor.util.retry.RetrySpec

Set the user provided context that can be used to manipulate state on retries.

withThrowable(Function<Flux<Throwable>, ? extends Publisher<?>>) - Static method in class reactor.util.retry.Retry

An adapter for Flux of Throwable-based Function to provide Retry from a legacy retryWhen Function.

withVirtualTime(Supplier<? extends Publisher<? extends T>>) - Static method in interface reactor.test.StepVerifier

Prepare a new StepVerifier in a controlled environment using VirtualTimeScheduler to manipulate a virtual clock via StepVerifier.Step.thenAwait().

withVirtualTime(Supplier<? extends Publisher<? extends T>>, long) - Static method in interface reactor.test.StepVerifier

Prepare a new StepVerifier in a controlled environment using VirtualTimeScheduler to manipulate a virtual clock via StepVerifier.Step.thenAwait().

withVirtualTime(Supplier<? extends Publisher<? extends T>>, Supplier<? extends VirtualTimeScheduler>, long) - Static method in interface reactor.test.StepVerifier

Prepare a new StepVerifier in a controlled environment using a user-provided VirtualTimeScheduler to manipulate a virtual clock via StepVerifier.Step.thenAwait().

withVirtualTime(Supplier<? extends Publisher<? extends T>>, StepVerifierOptions) - Static method in interface reactor.test.StepVerifier

Prepare a new StepVerifier in a controlled environment using a user-provided VirtualTimeScheduler to manipulate a virtual clock via StepVerifier.Step.thenAwait().

wrap(Subscriber<IN>, Publisher<OUT>) - Static method in class reactor.core.publisher.FluxProcessor

Deprecated.

Transform a receiving Subscriber and a producing Publisher in a logical FluxProcessor.

wrapQueue(Queue<T>) - Static method in class reactor.core.publisher.Hooks

Applies the Queue wrappers that were previously registered.

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

Wrap a Throwable delivered via Subscriber.onError(Throwable) from an upstream Publisher that itself emits Publishers to distinguish the error signal from the inner sequence's processing errors.

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

writeValues(Map<Object, Object>, Context) - Method in class reactor.util.context.ReactorContextAccessor

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