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 

U

unbounded() - Static method in class reactor.util.concurrent.Queues
 
unbounded(int) - Static method in class reactor.util.concurrent.Queues
Returns an unbounded, linked-array-based Queue.
unboundedMultiproducer() - Static method in class reactor.util.concurrent.Queues
Returns an unbounded queue suitable for multi-producer/single-consumer (MPSC) scenarios.
unicast() - Method in interface reactor.core.publisher.Sinks.ManySpec
Help building Sinks.Many that will broadcast signals to a single Subscriber
UnicastProcessor<T> - Class in reactor.core.publisher
Deprecated.
to be removed in 3.5, prefer clear cut usage of Sinks through variations under Sinks.many().unicast().
UnicastProcessor(Queue<T>) - Constructor for class reactor.core.publisher.UnicastProcessor
Deprecated.
 
UnicastProcessor(Queue<T>, Disposable) - Constructor for class reactor.core.publisher.UnicastProcessor
Deprecated.
 
UnicastProcessor(Queue<T>, Consumer<? super T>, Disposable) - Constructor for class reactor.core.publisher.UnicastProcessor
Deprecated.
unsafe() - Static method in class reactor.core.publisher.Sinks
Return a root spec for more advanced use cases such as building operators.
unwrap(Throwable) - Static method in class reactor.core.Exceptions
Unwrap a particular Throwable only if it is was wrapped via bubble or propagate.
unwrapMultiple(Throwable) - Static method in class reactor.core.Exceptions
Attempt to unwrap a Throwable into a List of Throwables.
unwrapMultipleExcludingTracebacks(Throwable) - Static method in class reactor.core.Exceptions
Attempt to unwrap a Throwable into a List of Throwables, excluding instances that are tracebacks.
update(Disposable) - Method in interface reactor.core.Disposable.Swap
Atomically set the next Disposable on this container and dispose the previous one (if any).
upstream() - Method in class reactor.core.publisher.BaseSubscriber
Return current Subscription
useConsoleLoggers() - Static method in class reactor.util.Loggers
Force the usage of Console-based Loggers, even if SLF4J is available on the classpath.
useCurrentLoggersWithCapture() - Static method in class reactor.test.util.LoggerUtils
Sets a logger factory that will return loggers that not only use the original logging framework used by reactor, but also use the logger set via LoggerUtils.enableCaptureWith(Logger), irrespective of its name or how it was obtained.
useCustomLoggers(Function<String, ? extends Logger>) - Static method in class reactor.util.Loggers
Use a custom type of Logger created through the provided Function, which takes a logger name as input.
useJdkLoggers() - Static method in class reactor.util.Loggers
Force the usage of JDK-based Loggers, even if SLF4J is available on the classpath.
useRegistry(MeterRegistry) - Static method in class reactor.util.Metrics.MicrometerConfiguration
Deprecated.
prefer using Micrometer setup in new reactor-core-micrometer module. To be removed at the earliest in 3.6.0.
useSl4jLoggers() - Static method in class reactor.util.Loggers
Force the usage of SL4J-based Loggers, throwing an exception if SLF4J isn't available on the classpath.
useVerboseConsoleLoggers() - Static method in class reactor.util.Loggers
Force the usage of Console-based Loggers, even if SLF4J is available on the classpath.
using(Callable<? extends D>, Function<? super D, ? extends Publisher<? extends T>>, Consumer<? super D>) - Static method in class reactor.core.publisher.Flux
Uses a resource, generated by a supplier for each individual Subscriber, while streaming the values from a Publisher derived from the same resource and makes sure the resource is released if the sequence terminates or the Subscriber cancels.
using(Callable<? extends D>, Function<? super D, ? extends Publisher<? extends T>>, Consumer<? super D>, boolean) - Static method in class reactor.core.publisher.Flux
Uses a resource, generated by a supplier for each individual Subscriber, while streaming the values from a Publisher derived from the same resource and makes sure the resource is released if the sequence terminates or the Subscriber cancels.
using(Callable<? extends D>, Function<? super D, ? extends Mono<? extends T>>, Consumer<? super D>, boolean) - Static method in class reactor.core.publisher.Mono
Uses a resource, generated by a supplier for each individual Subscriber, while streaming the value from a Mono derived from the same resource and makes sure the resource is released if the sequence terminates or the Subscriber cancels.
using(Callable<? extends D>, Function<? super D, ? extends Mono<? extends T>>, Consumer<? super D>) - Static method in class reactor.core.publisher.Mono
Uses a resource, generated by a supplier for each individual Subscriber, while streaming the value from a Mono derived from the same resource and makes sure the resource is released if the sequence terminates or the Subscriber cancels.
usingWhen(Publisher<D>, Function<? super D, ? extends Publisher<? extends T>>, Function<? super D, ? extends Publisher<?>>) - Static method in class reactor.core.publisher.Flux
Uses a resource, generated by a Publisher for each individual Subscriber, while streaming the values from a Publisher derived from the same resource.
usingWhen(Publisher<D>, Function<? super D, ? extends Publisher<? extends T>>, Function<? super D, ? extends Publisher<?>>, BiFunction<? super D, ? super Throwable, ? extends Publisher<?>>, Function<? super D, ? extends Publisher<?>>) - Static method in class reactor.core.publisher.Flux
Uses a resource, generated by a Publisher for each individual Subscriber, while streaming the values from a Publisher derived from the same resource.
usingWhen(Publisher<D>, Function<? super D, ? extends Mono<? extends T>>, Function<? super D, ? extends Publisher<?>>) - Static method in class reactor.core.publisher.Mono
Uses a resource, generated by a Publisher for each individual Subscriber, to derive a Mono.
usingWhen(Publisher<D>, Function<? super D, ? extends Mono<? extends T>>, Function<? super D, ? extends Publisher<?>>, BiFunction<? super D, ? super Throwable, ? extends Publisher<?>>, Function<? super D, ? extends Publisher<?>>) - Static method in class reactor.core.publisher.Mono
Uses a resource, generated by a Publisher for each individual Subscriber, to derive a Mono.Note that all steps of the operator chain that would need the resource to be in an open stable state need to be described inside the resourceClosure Function.
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