Skip navigation links
Reactor Core
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 

L

LARGE_BUFFERED - Static variable in class reactor.core.Scannable.Attr
Similar to Scannable.Attr.BUFFERED, but reserved for operators that can hold a backlog of items that can grow beyond Integer.MAX_VALUE.
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.
latest() - Method in interface reactor.core.publisher.Sinks.MulticastReplaySpec
A Sinks.Many with the following characteristics: Multicast Without Subscriber: the latest element pushed to this sink are remembered, even when there is no subscriber.
latestOrDefault(T) - Method in interface reactor.core.publisher.Sinks.MulticastReplaySpec
A Sinks.Many with the following characteristics: Multicast Without Subscriber: the latest element pushed to this sink are remembered, even when there is no subscriber. Backpressure : this sink honors downstream demand of individual subscribers. Replaying: the latest element pushed to this sink is replayed to new subscribers.
lift(BiFunction<Scannable, ? super CoreSubscriber<? super O>, ? extends CoreSubscriber<? super I>>) - Static method in class reactor.core.publisher.Operators
Create a function that can be used to support a custom operator via CoreSubscriber decoration.
lift(Predicate<Scannable>, BiFunction<Scannable, ? super CoreSubscriber<? super O>, ? extends CoreSubscriber<? super O>>) - Static method in class reactor.core.publisher.Operators
Create a function that can be used to support a custom operator via CoreSubscriber decoration.
LIFTER - Static variable in class reactor.core.Scannable.Attr
LIFTER attribute exposes name of the lifter function.
liftPublisher(BiFunction<Publisher, ? super CoreSubscriber<? super O>, ? extends CoreSubscriber<? super I>>) - Static method in class reactor.core.publisher.Operators
Create a function that can be used to support a custom operator via CoreSubscriber decoration.
liftPublisher(Predicate<Publisher>, BiFunction<Publisher, ? super CoreSubscriber<? super O>, ? extends CoreSubscriber<? super O>>) - Static method in class reactor.core.publisher.Operators
Create a function that can be used to support a custom operator via CoreSubscriber decoration.
limit(int) - Method in interface reactor.core.publisher.Sinks.MulticastReplaySpec
A Sinks.Many with the following characteristics: Multicast Without Subscriber: up to historySize elements pushed to this sink are remembered, even when there is no subscriber.
limit(Duration) - 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 until their maxAge is reached, even when there is no subscriber.
limit(Duration, Scheduler) - 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 until their maxAge is reached, even when there is no subscriber.
limit(int, Duration) - Method in interface reactor.core.publisher.Sinks.MulticastReplaySpec
A Sinks.Many with the following characteristics: Multicast Without Subscriber: up to historySize elements pushed to this sink are remembered, until their maxAge is reached, even when there is no subscriber.
limit(int, Duration, Scheduler) - Method in interface reactor.core.publisher.Sinks.MulticastReplaySpec
A Sinks.Many with the following characteristics: Multicast Without Subscriber: up to historySize elements pushed to this sink are remembered, until their maxAge is reached, even when there is no subscriber.
limitRate(int) - Method in class reactor.core.publisher.Flux
Ensure that backpressure signals from downstream subscribers are split into batches capped at the provided prefetchRate when propagated upstream, effectively rate limiting the upstream Publisher.
limitRate(int, int) - Method in class reactor.core.publisher.Flux
Ensure that backpressure signals from downstream subscribers are split into batches capped at the provided highTide first, then replenishing at the provided lowTide, effectively rate limiting the upstream Publisher.
limitRequest(long) - Method in class reactor.core.publisher.Flux
Deprecated.
replace with take(n, true) in 3.4.x, then Flux.take(long) in 3.5.0. To be removed in 3.6.0 at the earliest. See https://github.com/reactor/reactor-core/issues/2339
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(Logger) - Method in class reactor.core.publisher.Flux
Observe Reactive Streams signals matching the passed filter options and trace them using a specific user-provided Logger, at Level.INFO level.
log(Logger, Level, boolean, SignalType...) - Method in class reactor.core.publisher.Flux
Observe Reactive Streams signals matching the passed filter options and trace them using a specific user-provided Logger, at the given 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(Logger) - Method in class reactor.core.publisher.Mono
Observe Reactive Streams signals matching the passed filter options and trace them using a specific user-provided Logger, at Level.INFO level.
log(Logger, Level, boolean, SignalType...) - Method in class reactor.core.publisher.Mono
Observe Reactive Streams signals matching the passed filter options and trace them using a specific user-provided Logger, at the given Level.
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.
log() - Method in interface reactor.test.StepVerifier
Activate debug logging of a description of the test scenario, as well as some details about certain verification steps.
Logger - Interface in reactor.util
Logger interface designed for internal Reactor usage.
Logger.ChoiceOfMessageSupplier - Interface in reactor.util
A kind of Predicate and Supplier mix, provides two variants of a message String depending on the level of detail desired.
Loggers - Class in reactor.util
Expose static methods to get a logger depending on the environment.
LoggerUtils - Class in reactor.test.util
This class eases testing interested in what reactor classes emit using loggers.
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 
Skip navigation links
Reactor Core