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

A

accept(Subscriber<? super T>) - Method in interface reactor.core.publisher.Signal

Propagate the signal represented by this Signal instance to a given Subscriber.

actual - Variable in class reactor.core.publisher.Operators.MonoSubscriber

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

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

Deprecated.

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

The direct dependent component downstream reference if any.

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

Indicate that for some purposes a Scannable should be used as additional source of information about a contiguous Scannable in the chain.

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

Return a Stream navigating the Subscriber chain (downward).

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

Add a Disposable to this container, if it is not disposed.

add(T) - Method in interface reactor.core.Fuseable.QueueSubscription

add(SinkManyBestEffort.DirectInner<T>) - Method in class reactor.core.publisher.DirectProcessor

Deprecated.

addAll(Collection<? extends Disposable>) - Method in interface reactor.core.Disposable.Composite

Adds the given collection of Disposables to the container or disposes them all if the container has been disposed.

addAll(Collection<? extends T>) - Method in interface reactor.core.Fuseable.QueueSubscription

addCallSiteInfo(P, String) - Static method in class reactor.core.publisher.Hooks

Deprecated.

Should only be used by the instrumentation, DOES NOT guarantee any compatibility

addCap(long, long) - Static method in class reactor.core.publisher.Operators

Cap an addition to Long.MAX_VALUE

addCap(AtomicLongFieldUpdater<T>, T, long) - Static method in class reactor.core.publisher.Operators

Concurrent addition bound to Long.MAX_VALUE.

addExecutorServiceDecorator(String, BiFunction<Scheduler, ScheduledExecutorService, ScheduledExecutorService>) - Static method in class reactor.core.scheduler.Schedulers

Set up an additional ScheduledExecutorService decorator for a given key only if that key is not already present.

addQueueWrapper(String, Function<Queue<?>, Queue<?>>) - Static method in class reactor.core.publisher.Hooks

Adds a wrapper for every Queue used in Reactor.

addReturnInfo(P, String) - Static method in class reactor.core.publisher.Hooks

Deprecated.

Should only be used by the instrumentation, DOES NOT guarantee any compatibility

addSuppressed(RuntimeException, Throwable) - Static method in class reactor.core.Exceptions

Safely suppress a Throwable on a RuntimeException.

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

Safely suppress a Throwable on an original Throwable.

addThrowable(AtomicReferenceFieldUpdater<T, Throwable>, T, Throwable) - Static method in class reactor.core.Exceptions

Update an empty atomic reference with the given exception, or combine further added exceptions together as suppressed exceptions under a root Throwable with the "Multiple exceptions" message, if the atomic reference already holds one.

addToContext(Context) - Method in interface reactor.core.observability.SignalListener

In some cases, the tap operation should alter the Context exposed by the operator in order to store additional data.

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

Triggers any tasks that have not yet been executed and that are scheduled to be executed at or before this VirtualTimeScheduler's present time.

advanceTimeBy(Duration) - Method in class reactor.test.scheduler.VirtualTimeScheduler

Moves the VirtualTimeScheduler's clock forward by a specified amount of time.

advanceTimeTo(Instant) - Method in class reactor.test.scheduler.VirtualTimeScheduler

Moves the VirtualTimeScheduler's clock to a particular moment in time.

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.

all() - Method in interface reactor.core.publisher.Sinks.MulticastReplaySpec

A Sinks.Many with the following characteristics: Multicast Without Subscriber: all elements pushed to this sink are remembered, even when there is no subscriber. Backpressure : this sink honors downstream demand of individual subscribers. Replaying: all elements pushed to this sink are replayed to new subscribers.

all(int) - Method in interface reactor.core.publisher.Sinks.MulticastReplaySpec

A Sinks.Many with the following characteristics: Multicast Without Subscriber: all elements pushed to this sink are remembered, even when there is no subscriber. Backpressure : this sink honors downstream demand of individual subscribers. Replaying: all elements pushed to this sink are replayed to new subscribers.

and(Publisher<?>) - Method in class reactor.core.publisher.Mono

Join the termination signals from this mono and another source into the returned void mono

ANY - 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, Function<Object, String>) - Method in interface reactor.test.ValueFormatters.Extractor

Given an arbitrary object and a ValueFormatters.ToStringConverter, if the object passes the ValueFormatters.Extractor.test(Object), extract elements from it and convert them using the ValueFormatters.ToStringConverter, joining the result together to obtain a customized String representation of both the container and its contents.

apply(DynamicType.Builder<?>, TypeDescription, ClassFileLocator) - Method in class reactor.tools.agent.ReactorDebugByteBuddyPlugin

apply(Object) - Method in class reactor.util.function.Tuples

applyTo(BlockHound.Builder) - Method in class reactor.core.scheduler.ReactorBlockHoundIntegration

arrayExtractor(Class<T[]>) - Static method in class reactor.test.ValueFormatters

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

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.

as(String) - Method in interface reactor.test.StepVerifier.Step

Set a description for the previous verification step.

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

Deprecated.

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

Deprecated.

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

Return a Flux view of this sink.

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

Deprecated.

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

Return a Mono view of this sink.

assertCancelled() - Method in class reactor.test.publisher.TestPublisher

Asserts that this publisher has had at least one subscriber that has been cancelled.

assertCancelled(int) - Method in class reactor.test.publisher.TestPublisher

Asserts that this publisher has had at least n subscribers that have been cancelled.

assertMaxRequested(long) - Method in class reactor.test.publisher.TestPublisher

Assert that the current maximum request of all this publisher's subscribers is <= n.

assertMinRequested(long) - Method in class reactor.test.publisher.TestPublisher

Assert that the current minimum request of all this publisher's subscribers is >= n.

assertNext(Consumer<? super T>) - Method in interface reactor.test.StepVerifier.Step

Expect an element and consume it with the given consumer, usually performing assertions on it (eg.

assertNoRequestOverflow() - Method in class reactor.test.publisher.TestPublisher

Asserts that this publisher has had no subscriber with request overflow.

assertNoSubscribers() - Method in class reactor.test.publisher.TestPublisher

Asserts that this publisher has no subscribers.

assertNotCancelled() - Method in class reactor.test.publisher.TestPublisher

Asserts that this publisher has had no cancelled subscribers.

assertRequestOverflow() - Method in class reactor.test.publisher.TestPublisher

Asserts that this publisher has had subscriber that saw request overflow, that is received an onNext event despite having a requested amount of 0 at the time.

assertSubscribers() - Method in class reactor.test.publisher.TestPublisher

Asserts that this publisher has subscribers.

assertSubscribers(int) - Method in class reactor.test.publisher.TestPublisher

Asserts that this publisher has exactly n subscribers.

assertThat(Consumer<Context>) - Method in interface reactor.test.StepVerifier.ContextExpectations

Apply custom assertions to the propagated Context.

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

Check that the probe was cancelled at least once, or throw an AssertionError.

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

Check that the probe was never cancelled, or throw an AssertionError.

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

Check that the probe was never requested, or throw an AssertionError.

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

Check that the probe was never subscribed to, or throw an AssertionError.

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

Check that the probe was requested at least once, or throw an AssertionError.

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

Check that the probe was subscribed to at least once, or throw an AssertionError.

ASYNC - Static variable in interface reactor.core.Fuseable

Indicates the QueueSubscription can perform only async-fusion.

Attr(T) - Constructor for class reactor.core.Scannable.Attr

Attr(T, Function<Object, ? extends T>) - Constructor for class reactor.core.Scannable.Attr

autoConnect() - Method in class reactor.core.publisher.ConnectableFlux

Connects this ConnectableFlux to the upstream source when the first Subscriber subscribes.

autoConnect(int) - Method in class reactor.core.publisher.ConnectableFlux

Connects this ConnectableFlux to the upstream source when the specified amount of Subscriber subscribes.

autoConnect(int, Consumer<? super Disposable>) - Method in class reactor.core.publisher.ConnectableFlux

Connects this ConnectableFlux to the upstream source when the specified amount of Subscriber subscribes and calls the supplied consumer with a Disposable that allows disconnecting.

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