- 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
-
- validate(Subscriber<?>[]) - Method in class reactor.core.publisher.ParallelFlux
-
Validates the number of subscribers and returns true if their number matches the
parallelism level of this ParallelFlux.
- validateArguments() - Method in class reactor.util.retry.RetryBackoffSpec
-
- value - Variable in class reactor.core.publisher.Operators.MonoSubscriber
-
The value stored by this Mono operator.
- valueFormatter(ValueFormatters.ToStringConverter) - Method in class reactor.test.StepVerifierOptions
-
Set up a custom value formatter to be used in error messages when presenting
expected and actual values.
- ValueFormatters - Class in reactor.test
-
- ValueFormatters.Extractor<CONTAINER> - Interface in reactor.test
-
- ValueFormatters.ToStringConverter - Interface in reactor.test
-
- valueOf(String) - Static method in enum reactor.core.observability.micrometer.MicrometerMeterListenerDocumentation.CommonTags
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.core.observability.micrometer.MicrometerMeterListenerDocumentation.TerminationTags
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.core.observability.micrometer.MicrometerMeterListenerDocumentation
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.core.observability.micrometer.MicrometerObservationListenerDocumentation.ObservationTags
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.core.observability.micrometer.MicrometerObservationListenerDocumentation
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.core.observability.micrometer.TimedSchedulerMeterDocumentation.SubmittedTags
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.core.observability.micrometer.TimedSchedulerMeterDocumentation
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.core.publisher.BufferOverflowStrategy
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.core.publisher.FluxSink.OverflowStrategy
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.core.publisher.SignalType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.core.publisher.Sinks.EmitResult
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.core.Scannable.Attr.RunStyle
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.test.publisher.TestPublisher.Violation
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.test.subscriber.TestSubscriber.FusionRequirement
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum reactor.core.observability.micrometer.MicrometerMeterListenerDocumentation.CommonTags
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.core.observability.micrometer.MicrometerMeterListenerDocumentation.TerminationTags
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.core.observability.micrometer.MicrometerMeterListenerDocumentation
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.core.observability.micrometer.MicrometerObservationListenerDocumentation.ObservationTags
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.core.observability.micrometer.MicrometerObservationListenerDocumentation
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.core.observability.micrometer.TimedSchedulerMeterDocumentation.SubmittedTags
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.core.observability.micrometer.TimedSchedulerMeterDocumentation
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.core.publisher.BufferOverflowStrategy
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.core.publisher.FluxSink.OverflowStrategy
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.core.publisher.SignalType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.core.publisher.Sinks.EmitResult
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.core.Scannable.Attr.RunStyle
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.test.publisher.TestPublisher.Violation
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.test.subscriber.TestSubscriber.FusionRequirement
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- verify() - Method in interface reactor.test.StepVerifier
-
Verify the signals received by this subscriber.
- verify(Duration) - Method in interface reactor.test.StepVerifier
-
Verify the signals received by this subscriber.
- verifyComplete() - Method in interface reactor.test.StepVerifier.LastStep
-
Trigger the
verification
, expecting a completion signal
as terminal event.
- verifyError() - Method in interface reactor.test.StepVerifier.LastStep
-
Trigger the
verification
, expecting an unspecified error
as terminal event.
- verifyError(Class<? extends Throwable>) - Method in interface reactor.test.StepVerifier.LastStep
-
Trigger the
verification
, expecting an error of the specified
type as terminal event.
- verifyErrorMatches(Predicate<Throwable>) - Method in interface reactor.test.StepVerifier.LastStep
-
Trigger the
verification
, expecting an error that matches
the given predicate as terminal event.
- verifyErrorMessage(String) - Method in interface reactor.test.StepVerifier.LastStep
-
Trigger the
verification
, expecting an error with the
specified message as terminal event.
- verifyErrorSatisfies(Consumer<Throwable>) - Method in interface reactor.test.StepVerifier.LastStep
-
Trigger the
verification
, expecting an error as terminal event
which gets asserted via assertion(s) provided as a
Consumer
.
- verifyLater() - Method in interface reactor.test.StepVerifier
-
Trigger the subscription and prepare for verifications but doesn't block.
- verifyThenAssertThat() - Method in interface reactor.test.StepVerifier
-
- verifyThenAssertThat(Duration) - Method in interface reactor.test.StepVerifier
-
- verifyTimeout(Duration) - Method in interface reactor.test.StepVerifier.LastStep
-
- VirtualTimeScheduler - Class in reactor.test.scheduler
-
A
Scheduler
that uses a virtual clock, allowing to manipulate time
(eg.
- VirtualTimeScheduler(boolean) - Constructor for class reactor.test.scheduler.VirtualTimeScheduler
-
- virtualTimeSchedulerSupplier(Supplier<? extends VirtualTimeScheduler>) - Method in class reactor.test.StepVerifierOptions
-