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

I

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

Ignores onNext signal (dropping it) and only propagates termination events.

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

Ignores onNext signals (dropping them) and only propagate termination events.

ignoreElements(Publisher<T>) - Static method in class reactor.core.publisher.Mono

Create a new Mono that ignores elements from the source (dropping them), but completes when the source completes.

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

Executes tasks immediately instead of scheduling them.

indefinitely() - Static method in class reactor.util.retry.Retry

A RetrySpec preconfigured for the most simplistic retry strategy: retry immediately and indefinitely (similar to Flux.retry()).

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

Keep information about the order in which source values were received by indexing them with a 0-based incrementing long, returning a Flux of Tuple2<(index, value)>.

index(BiFunction<? super Long, ? super T, ? extends I>) - Method in class reactor.core.publisher.Flux

Keep information about the order in which source values were received by indexing them internally with a 0-based incrementing long then combining this information with the source value into a I using the provided BiFunction, returning a Flux<I>.

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

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

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

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

Log a message at the INFO level.

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

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

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

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

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

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

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

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

init() - Method in interface reactor.core.scheduler.Scheduler

Instructs this Scheduler to prepare itself for running tasks directly or through its Scheduler.Workers.

init() - Static method in class reactor.tools.agent.ReactorDebugAgent

initializePublisherState(Publisher<? extends T>) - Method in interface reactor.core.observability.SignalListenerFactory

Create the STATE object for the given Publisher.

initialRequest(long) - Method in class reactor.test.StepVerifierOptions

Set the amount the StepVerifier should request initially.

initialRequest(long) - Method in class reactor.test.subscriber.TestSubscriberBuilder

Set the request to be made upon receiving the Subscription in Subscriber.onSubscribe(Subscription).

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

Set the request to be made upon receiving the Subscription in Subscriber.onSubscribe(Subscription) to be an unbounded request, ie.

inners() - Method in class reactor.core.publisher.DirectProcessor

Deprecated.

inners() - Method in class reactor.core.publisher.EmitterProcessor

Deprecated.

inners() - Method in class reactor.core.publisher.FluxProcessor

Deprecated.

inners() - Method in class reactor.core.publisher.MonoProcessor

Deprecated.

inners() - Method in class reactor.core.publisher.ReplayProcessor

Deprecated.

inners() - Method in class reactor.core.publisher.UnicastProcessor

Deprecated.

inners() - Method in interface reactor.core.Scannable

Return a Stream of referenced inners (flatmap, multicast etc)

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

Create a Flux that emits long values starting with 0 and incrementing at specified time intervals on the global timer.

interval(Duration, Duration) - Static method in class reactor.core.publisher.Flux

Create a Flux that emits long values starting with 0 and incrementing at specified time intervals, after an initial delay, on the global timer.

interval(Duration, 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.

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

Check if the given exception is a bubbled wrapped exception.

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

Check if the given error is a cancel signal.

isCancelled() - Method in class reactor.core.publisher.EmitterProcessor

Deprecated.

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

Returns true if the downstream cancelled the sequence.

isCancelled() - Method in class reactor.core.publisher.MonoProcessor

Deprecated.

the MonoProcessor will cease to implement Subscription and this method will be removed in 3.5

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

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

Returns true if this Subscription has been cancelled.

isCancelled() - Method in interface reactor.test.subscriber.TestSubscriber

Check if this TestSubscriber has been cancelled, which implies TestSubscriber.isTerminatedOrCancelled() is also true.

isCheckUnderRequesting() - Method in class reactor.test.StepVerifierOptions

isComplete(Object) - Static method in interface reactor.core.publisher.Signal

Check if an arbitrary Object represents a COMPLETE Signal.

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

isDebugEnabled() - Method in interface reactor.util.Logger

Is the logger instance enabled for the DEBUG level?

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

Indicates if the container has already been disposed.

isDisposed() - Method in interface reactor.core.Disposable

Optionally return true when the resource or task is disposed.

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

isDisposed() - Method in class reactor.core.publisher.EmitterProcessor

Deprecated.

isDisposed() - Method in class reactor.core.publisher.MonoProcessor

Deprecated.

isDisposed() - Method in class reactor.core.publisher.UnicastProcessor

Deprecated.

isDisposed() - Method in class reactor.core.scheduler.Schedulers.Snapshot

isDisposed() - Method in class reactor.test.scheduler.VirtualTimeScheduler

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

isEmpty() - Method in class reactor.core.publisher.UnicastProcessor

Deprecated.

isEmpty() - Method in interface reactor.util.context.ContextView

Return true if the Context is empty.

isError() - Method in class reactor.core.publisher.MonoProcessor

Deprecated.

Indicates whether this MonoProcessor has been completed with an error.

isError(Object) - Static method in interface reactor.core.publisher.Signal

Check if a arbitrary Object represents an ERROR Signal.

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

Check if the given error is a callback not implemented exception, in which case its cause will be the propagated error that couldn't be processed.

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

isErrorEnabled() - Method in interface reactor.util.Logger

Is the logger instance enabled for the ERROR level?

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

Return true if there is a VirtualTimeScheduler currently used by the Schedulers factory (ie it has been enabled), false otherwise (ie it has been reset).

isFailure() - Method in enum reactor.core.publisher.Sinks.EmitResult

Represents a failure to emit a signal.

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

Check if a Throwable is considered by Reactor as Fatal and would be thrown by Exceptions.throwIfFatal(Throwable).

isIdentityProcessor() - Method in class reactor.core.publisher.DirectProcessor

Deprecated.

isIdentityProcessor() - Method in class reactor.core.publisher.EmitterProcessor

Deprecated.

isIdentityProcessor() - Method in class reactor.core.publisher.FluxProcessor

Deprecated.

Return true if FluxProcessor<T, T>

isIdentityProcessor() - Method in class reactor.core.publisher.ReplayProcessor

Deprecated.

isIdentityProcessor() - Method in class reactor.core.publisher.UnicastProcessor

Deprecated.

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

isInfoEnabled() - Method in interface reactor.util.Logger

Is the logger instance enabled for the INFO level?

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

Check if calling a Reactor blocking API in the current Thread is forbidden or not, by checking if the thread implements NonBlocking (in which case it is forbidden and this method returns true).

isInstrumentationAvailable() - Static method in class reactor.util.Metrics

Deprecated.

prefer explicit usage of the reactor-core-micrometer module. To be removed in 3.6.0 at the earliest.

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

Check if a Throwable is considered by Reactor as Jvm Fatal and would be thrown by both Exceptions.throwIfFatal(Throwable) and Exceptions.throwIfJvmFatal(Throwable).

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

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

Check a Throwable to see if it is a composite, as created by Exceptions.multiple(Throwable...).

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

Check if calling a Reactor blocking API in the given Thread is forbidden or not, by checking if the thread implements NonBlocking (in which case it is forbidden and this method returns true).

isOnComplete() - Method in interface reactor.core.publisher.Signal

Indicates whether this signal represents an onComplete event.

isOnError() - Method in interface reactor.core.publisher.Signal

Indicates whether this signal represents an onError event.

isOnNext() - Method in interface reactor.core.publisher.Signal

Indicates whether this signal represents an onNext event.

isOnSubscribe() - Method in interface reactor.core.publisher.Signal

Indicates whether this signal represents an onSubscribe event.

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

Check if the given exception represents an overflow.

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

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

Check a Throwable to see if it indicates too many retry attempts have failed.

isScanAvailable() - Method in interface reactor.core.Scannable

Return true whether the component is available for Scannable.scan(Attr) resolution.

isSerialized() - Method in class reactor.core.publisher.FluxProcessor

Deprecated.

Return true if this FluxProcessor supports multithread producing

isSuccess() - Method in class reactor.core.publisher.MonoProcessor

Deprecated.

Indicates whether this MonoProcessor has been successfully completed a value.

isSuccess() - Method in enum reactor.core.publisher.Sinks.EmitResult

Represents a successful emission of a signal.

isTerminated() - Method in class reactor.core.publisher.DirectProcessor

Deprecated.

isTerminated() - Method in class reactor.core.publisher.EmitterProcessor

Deprecated.

isTerminated() - Method in class reactor.core.publisher.FluxProcessor

Deprecated.

Has this upstream finished or "completed" / "failed" ?

isTerminated() - Method in class reactor.core.publisher.MonoProcessor

Deprecated.

Indicates whether this MonoProcessor has been terminated by the source producer with a success or an error.

isTerminated() - Method in class reactor.core.publisher.ReplayProcessor

Deprecated.

isTerminated() - Method in class reactor.core.publisher.UnicastProcessor

Deprecated.

isTerminated() - Method in interface reactor.test.subscriber.TestSubscriber

Check if this TestSubscriber has received a terminal signal, ie.

isTerminatedComplete() - Method in interface reactor.test.subscriber.TestSubscriber

Check if this TestSubscriber has received a terminal signal that is specifically onComplete.

isTerminatedError() - Method in interface reactor.test.subscriber.TestSubscriber

Check if this TestSubscriber has received a terminal signal that is specifically onError.

isTerminatedOrCancelled() - Method in interface reactor.test.subscriber.TestSubscriber

Check if this TestSubscriber has either: been cancelled: TestSubscriber.isCancelled() would return true been terminated, having been signalled with onComplete or onError: TestSubscriber.isTerminated() would return true and TestSubscriber.getTerminalSignal() would return a non-null Signal The third possible failure condition, subscription failure, results in an AssertionError being thrown by this method (like all other accessors, see also TestSubscriber javadoc).

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

Check a Throwable to see if it is a traceback, as created by the checkpoint operator or debug utilities.

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

isTraceEnabled() - Method in interface reactor.util.Logger

Is the logger instance enabled for the TRACE level?

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

The configured transient error handling flag.

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

The configured transient error handling flag.

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

isWarnEnabled() - Method in interface reactor.util.Logger

Is the logger instance enabled for the WARN level?

iterableExtractor() - Static method in class reactor.test.ValueFormatters

Default Iterable extractor that use the [CONVERTED1, CONVERTED2] representation.

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

iterator() - Method in class reactor.util.function.Tuple2

Return an immutable Iterator<Object> around the content of this Tuple.

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