跳过导航链接
A B C D E F G H I J K L M N O P Q R S T U V W X Y Z 

U

unavailableScan() - 类 中的方法reactor.core.ScannableTest
 
unbounded() - 类 中的方法reactor.core.publisher.SinkManyReplayProcessorTest
 
unbounded() - 类 中的静态方法reactor.util.concurrent.Queues
 
unbounded(int) - 类 中的静态方法reactor.util.concurrent.Queues
Returns an unbounded, linked-array-based Queue.
unboundedAfter() - 类 中的方法reactor.core.publisher.SinkManyReplayProcessorTest
 
unboundedFused() - 类 中的方法reactor.core.publisher.SinkManyReplayProcessorTest
 
unboundedFusedError() - 类 中的方法reactor.core.publisher.SinkManyReplayProcessorTest
 
unboundedLong() - 类 中的方法reactor.core.publisher.SinkManyReplayProcessorTest
 
unboundedMultiproducer() - 类 中的静态方法reactor.util.concurrent.Queues
Returns an unbounded queue suitable for multi-producer/single-consumer (MPSC) scenarios.
unboundedOnSubscribeAndState() - 类 中的方法reactor.core.publisher.SinkManyReplayProcessorTest
 
unboundedOrLimit() - 类 中的方法reactor.core.publisher.OperatorsTest
 
unboundedOrLimitLowTide() - 类 中的方法reactor.core.publisher.OperatorsTest
 
unboundedOrPrefetch() - 类 中的方法reactor.core.publisher.OperatorsTest
 
unicast() - 接口 中的方法reactor.core.publisher.Sinks.ManySpec
Help building Sinks.Many that will broadcast signals to a single Subscriber
UnicastProcessor<T> - reactor.core.publisher中的类
已过时。
to be removed in 3.5, prefer clear cut usage of Sinks through variations under Sinks.many().unicast().
UnicastProcessor(Queue<T>) - 类 的构造器reactor.core.publisher.UnicastProcessor
已过时。
 
UnicastProcessor(Queue<T>, Disposable) - 类 的构造器reactor.core.publisher.UnicastProcessor
已过时。
 
UnicastProcessor(Queue<T>, Consumer<? super T>, Disposable) - 类 的构造器reactor.core.publisher.UnicastProcessor
已过时。
unimplementedErrorCallback(TestLogger) - 类 中的方法reactor.core.publisher.scenarios.FluxTests
 
unmatchingSignal() - 类 中的方法reactor.core.publisher.SignalTest
 
unsafe() - 类 中的静态方法reactor.core.publisher.Sinks
Return a root spec for more advanced use cases such as building operators.
unsafePutAllIntoIsNoOp() - 类 中的方法reactor.util.context.Context0Test
 
unsafePutAllIntoShouldReplace() - 类 中的方法reactor.util.context.Context1Test
 
unsafePutAllIntoShouldReplace() - 类 中的方法reactor.util.context.Context2Test
 
unsafePutAllIntoShouldReplace() - 类 中的方法reactor.util.context.Context3Test
 
unsafePutAllIntoShouldReplace() - 类 中的方法reactor.util.context.Context4Test
 
unsafePutAllIntoShouldReplace() - 类 中的方法reactor.util.context.Context5Test
 
unsubscribingTwiceDoesUnsubscribeOnce() - 类 中的方法reactor.core.SwapDisposableTest
 
unsubscribingWithoutUnderlyingDoesNothing() - 类 中的方法reactor.core.SwapDisposableTest
 
unsubscribingWithSingleUnderlyingUnsubscribes() - 类 中的方法reactor.core.SwapDisposableTest
 
untilChangedDisposesStateOnCancel() - 类 中的方法reactor.core.publisher.FluxBufferPredicateTest
 
untilChangedDisposesStateOnCancel() - 类 中的方法reactor.core.publisher.FluxWindowPredicateTest
 
untilChangedDisposesStateOnComplete() - 类 中的方法reactor.core.publisher.FluxBufferPredicateTest
 
untilChangedDisposesStateOnComplete() - 类 中的方法reactor.core.publisher.FluxWindowPredicateTest
 
untilChangedDisposesStateOnError() - 类 中的方法reactor.core.publisher.FluxBufferPredicateTest
 
untilChangedDisposesStateOnError() - 类 中的方法reactor.core.publisher.FluxWindowPredicateTest
 
untilChangedNoRepetition() - 类 中的方法reactor.core.publisher.FluxBufferPredicateTest
 
untilChangedNoRepetition() - 类 中的方法reactor.core.publisher.FluxWindowPredicateTest
 
untilChangedNoSharedState() - 类 中的方法reactor.core.publisher.FluxBufferPredicateTest
 
untilChangedSomeRepetition() - 类 中的方法reactor.core.publisher.FluxBufferPredicateTest
 
untilChangedSomeRepetition() - 类 中的方法reactor.core.publisher.FluxWindowPredicateTest
 
untilChangedWithKeySelector() - 类 中的方法reactor.core.publisher.FluxBufferPredicateTest
 
unwrap(Throwable) - 类 中的静态方法reactor.core.Exceptions
Unwrap a particular Throwable only if it is was wrapped via bubble or propagate.
unwrapMultiple(Throwable) - 类 中的静态方法reactor.core.Exceptions
Attempt to unwrap a Throwable into a List of Throwables.
unwrapMultipleExcludingTraceback() - 类 中的方法reactor.core.ExceptionsTest
 
unwrapMultipleExcludingTracebacks(Throwable) - 类 中的静态方法reactor.core.Exceptions
Attempt to unwrap a Throwable into a List of Throwables, excluding instances that are tracebacks.
unwrapMultipleNotComposite() - 类 中的方法reactor.core.ExceptionsTest
 
unwrapMultipleNull() - 类 中的方法reactor.core.ExceptionsTest
 
update(Disposable) - 接口 中的方法reactor.core.Disposable.Swap
Atomically set the next Disposable on this container and dispose the previous one (if any).
upstream() - 类 中的方法reactor.test.subscriber.AssertSubscriber
 
upstreamCompletes() - 类 中的方法reactor.core.publisher.FluxRefCountGraceTest
 
upstreamCompletes() - 类 中的方法reactor.core.publisher.FluxRefCountTest
 
upstreamCompletesTwoSubscribers() - 类 中的方法reactor.core.publisher.FluxRefCountGraceTest
 
upstreamCompletesTwoSubscribers() - 类 中的方法reactor.core.publisher.FluxRefCountTest
 
upstreamIsDelayedSource() - 类 中的方法reactor.core.publisher.MonoDelayElementTest
 
useConsoleLoggers() - 类 中的静态方法reactor.util.Loggers
Force the usage of Console-based Loggers, even if SLF4J is available on the classpath.
useCurrentLoggersWithCapture() - 类 中的静态方法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>) - 类 中的静态方法reactor.util.Loggers
Use a custom type of Logger created through the provided Function, which takes a logger name as input.
useJdkLoggers() - 类 中的静态方法reactor.util.Loggers
Force the usage of JDK-based Loggers, even if SLF4J is available on the classpath.
useRegistry(MeterRegistry) - 类 中的静态方法reactor.util.Metrics.MicrometerConfiguration
已过时。
prefer using Micrometer setup in new reactor-core-micrometer module. To be removed at the earliest in 3.6.0.
userWorkerShutdownBySchedulerDisposal(boolean) - 类 中的方法reactor.core.scheduler.BoundedElasticSchedulerTest
 
usesFluxDoOnEachConditionalSubscriber() - 类 中的方法reactor.core.publisher.MonoDoOnEachTest
 
usesFluxDoOnEachSubscriber() - 类 中的方法reactor.core.publisher.MonoDoOnEachTest
 
useSl4jLoggers() - 类 中的静态方法reactor.util.Loggers
Force the usage of SL4J-based Loggers, throwing an exception if SLF4J isn't available on the classpath.
usesTags() - 类 中的方法reactor.core.publisher.FluxMetricsTest
 
usesTags() - 类 中的方法reactor.core.publisher.MonoMetricsTest
 
usesTagsFuseable() - 类 中的方法reactor.core.publisher.FluxMetricsFuseableTest
 
usesTagsFuseable() - 类 中的方法reactor.core.publisher.MonoMetricsFuseableTest
 
useVerboseConsoleLoggers() - 类 中的静态方法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>) - 类 中的静态方法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) - 类 中的静态方法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) - 类 中的静态方法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>) - 类 中的静态方法reactor.core.publisher.Mono
主要将一个资源使用工厂方法方式为每个订阅者生成资源,第一个参数在订阅时创建资源,第二个参数 一个Mono工厂创建 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<?>>) - 类 中的静态方法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<?>>) - 类 中的静态方法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<?>>) - 类 中的静态方法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<?>>) - 类 中的静态方法reactor.core.publisher.Mono
工厂方法模式创建一个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 Y Z 
跳过导航链接