类的使用
reactor.util.annotation.Nullable

使用Nullable的程序包

程序包	说明
reactor.core	Core components of the framework supporting extensions to the Reactive Stream programming model.
reactor.core.publisher	Provide main Reactive APIs in Flux and Mono, as well as various helper classes, interfaces used in the composition API, variants of Flux and operator-building utilities.
reactor.core.scheduler	Scheduler contract and static registry and factory methods in Schedulers.
reactor.test	Main test components supporting the testing and assertion of publishers.
reactor.test.publisher	Components supporting the creation of test-oriented Publishers.
reactor.test.subscriber	Components supporting the creation of test-oriented Subscribers.
reactor.util.context	Miscellaneous utility classes, such as loggers, tuples or queue suppliers and implementations.
reactor.util.function	Tuples provide a type-safe way to specify multiple parameters.
reactor.util.retry

reactor.core中Nullable的使用

注释类型为Nullable的reactor.core中的方法

限定符和类型	方法和说明
T	Scannable.Attr.defaultValue() Meaningful and always applicable default value for the attribute, returned instead of null when a specific value hasn't been defined for a component.
default T	Fuseable.QueueSubscription.peek()
java.lang.Object	TestLoggerExtension.resolveParameter(org.junit.jupiter.api.extension.ParameterContext parameterContext, org.junit.jupiter.api.extension.ExtensionContext extensionContext)
default <T> T	Scannable.scan(Scannable.Attr<T> key) 内省方法，扫描返回自身组件 Scannable.Attr 的属性值 Introspect a component's specific state attribute, returning an associated value specific to that component, or the default value associated with the key, or null if the attribute doesn't make sense for that particular component and has no sensible default.
java.lang.Object	Scannable.scanUnsafe(Scannable.Attr key) This method is used internally by components to define their key-value mappings in a single place.
static <T> java.lang.Throwable	Exceptions.terminate(java.util.concurrent.atomic.AtomicReferenceFieldUpdater<T,java.lang.Throwable> field, T instance) Atomic utility to safely mark a volatile throwable reference with a terminal marker.

注释类型为Nullable的reactor.core中的方法参数

限定符和类型	方法和说明
default boolean	Fuseable.QueueSubscription.add(T t)
default boolean	Fuseable.QueueSubscription.contains(java.lang.Object o)
static Scannable	Scannable.from(java.lang.Object o) Attempt to cast the Object to a Scannable.
static boolean	Exceptions.isBubbling(java.lang.Throwable t) Check if the given exception is a bubbled wrapped exception.
static boolean	Exceptions.isCancel(java.lang.Throwable t) Check if the given error is a cancel signal.
static boolean	Exceptions.isErrorCallbackNotImplemented(java.lang.Throwable t) 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.
static boolean	Exceptions.isFatal(java.lang.Throwable t) Check if a Throwable is considered by Reactor as Fatal and would be thrown by Exceptions.throwIfFatal(Throwable).
static boolean	Exceptions.isJvmFatal(java.lang.Throwable t) Check if a Throwable is considered by Reactor as Jvm Fatal and would be thrown by both Exceptions.throwIfFatal(Throwable) and Exceptions.throwIfJvmFatal(Throwable).
static boolean	Exceptions.isMultiple(java.lang.Throwable t) Check a Throwable to see if it is a composite, as created by Exceptions.multiple(Throwable...).
static boolean	Exceptions.isOverflow(java.lang.Throwable t) Check if the given exception represents an overflow.
static boolean	Exceptions.isRetryExhausted(java.lang.Throwable t) Check a Throwable to see if it indicates too many retry attempts have failed.
static boolean	Exceptions.isTraceback(java.lang.Throwable t) Check a Throwable to see if it is a traceback, as created by the checkpoint operator or debug utilities.
default boolean	Fuseable.QueueSubscription.offer(T t)
default boolean	Fuseable.QueueSubscription.remove(java.lang.Object o)
boolean	Disposable.Swap.replace(Disposable next) Atomically set the next Disposable on this container but don't dispose the previous one (if any).
static java.lang.RuntimeException	Exceptions.retryExhausted(java.lang.String message, java.lang.Throwable cause) Return a new RuntimeException that represents too many failures on retry.
static void	Exceptions.throwIfFatal(java.lang.Throwable t) Throws a particular Throwable only if it belongs to a set of "fatal" error varieties.
static void	Exceptions.throwIfJvmFatal(java.lang.Throwable t) Throws a particular Throwable only if it belongs to a set of "fatal" error varieties native to the JVM.
static java.util.List<java.lang.Throwable>	Exceptions.unwrapMultiple(java.lang.Throwable potentialMultiple) Attempt to unwrap a Throwable into a List of Throwables.
static java.util.List<java.lang.Throwable>	Exceptions.unwrapMultipleExcludingTracebacks(java.lang.Throwable potentialMultiple) Attempt to unwrap a Throwable into a List of Throwables, excluding instances that are tracebacks.
boolean	Disposable.Swap.update(Disposable next) Atomically set the next Disposable on this container and dispose the previous one (if any).

reactor.core.publisher中Nullable的使用

注释类型为Nullable的reactor.core.publisher中的方法

限定符和类型	方法和说明
static <T,P extends org.reactivestreams.Publisher<T>> org.reactivestreams.Publisher<T>	Hooks.addCallSiteInfo(P publisher, java.lang.String callSite) 已过时。 Should only be used by the instrumentation, DOES NOT guarantee any compatibility
static <T,P extends org.reactivestreams.Publisher<T>> org.reactivestreams.Publisher<T>	Hooks.addReturnInfo(P publisher, java.lang.String method) 已过时。 Should only be used by the instrumentation, DOES NOT guarantee any compatibility
static <T> Fuseable.QueueSubscription<T>	Operators.as(org.reactivestreams.Subscription s) Returns the subscription as QueueSubscription if possible or null.
O	MonoProcessor.block() 已过时。 Block the calling thread indefinitely, waiting for the completion of this MonoProcessor.
T	Mono.block() 定阅此Mono并无限期阻塞，直到接收到下一个信号并返回该值 Subscribe to this Mono and block indefinitely until a next signal is received.
O	MonoProcessor.block(java.time.Duration timeout) 已过时。 Block the calling thread for the specified time, waiting for the completion of this MonoProcessor.
T	Mono.block(java.time.Duration timeout) 订阅此Mono并阻塞，直到收到下一个信号或超时到期。
T	Flux.blockFirst() Subscribe to this Flux and block indefinitely until the upstream signals its first value or completes.
T	Flux.blockFirst(java.time.Duration timeout) Subscribe to this Flux and block until the upstream signals its first value, completes or a timeout expires.
T	Flux.blockLast() Subscribe to this Flux and block indefinitely until the upstream signals its last value or completes.
T	Flux.blockLast(java.time.Duration timeout) Subscribe to this Flux and block until the upstream signals its last value, completes or a timeout expires.
T	Signal.get() Retrieves the item associated with this (onNext) signal.
java.lang.Throwable	MonoProcessor.getError() 已过时。 Return the produced Throwable error if any or null
java.lang.Throwable	FluxProcessor.getError() 已过时。 Current error if any, default to null
java.lang.Throwable	EmitterProcessor.getError() 已过时。
java.lang.Throwable	ReplayProcessor.getError() 已过时。
java.lang.Throwable	UnicastProcessor.getError() 已过时。
java.lang.Throwable	DirectProcessor.getError() 已过时。
org.reactivestreams.Subscription	Signal.getSubscription() Read the subscription associated with this (onSubscribe) signal.
java.lang.Throwable	Signal.getThrowable() Read the error associated with this (onError) signal.
static <T> java.lang.Throwable	Operators.onNextError(T value, java.lang.Throwable error, Context context) Find the OnNextFailureStrategy to apply to the calling async operator (which could be a local error mode defined in the Context) and apply it.
static <T> java.lang.Throwable	Operators.onNextError(T value, java.lang.Throwable error, Context context, org.reactivestreams.Subscription subscriptionForCancel) Find the OnNextFailureStrategy to apply to the calling operator (which could be a local error mode defined in the Context) and apply it.
static <T> java.lang.RuntimeException	Operators.onNextPollError(T value, java.lang.Throwable error, Context context) Find the OnNextFailureStrategy to apply to the calling async operator (which could be a local error mode defined in the Context) and apply it.
O	MonoProcessor.peek() 已过时。 this method is discouraged, consider peeking into a MonoProcessor by turning it into a CompletableFuture
T	UnicastProcessor.poll() 已过时。
O	Operators.MonoSubscriber.poll()
java.lang.Object	MonoProcessor.scanUnsafe(Scannable.Attr key) 已过时。
java.lang.Object	FluxOperator.scanUnsafe(Scannable.Attr key)
java.lang.Object	FluxProcessor.scanUnsafe(Scannable.Attr key) 已过时。
java.lang.Object	EmitterProcessor.scanUnsafe(Scannable.Attr key) 已过时。
java.lang.Object	ReplayProcessor.scanUnsafe(Scannable.Attr key) 已过时。
java.lang.Object	MonoOperator.scanUnsafe(Scannable.Attr key)
java.lang.Object	Operators.DeferredSubscription.scanUnsafe(Scannable.Attr key)
java.lang.Object	Operators.MonoSubscriber.scanUnsafe(Scannable.Attr key)

注释类型为Nullable的reactor.core.publisher中的方法参数

限定符和类型	方法和说明
static <T,P extends org.reactivestreams.Publisher<T>> org.reactivestreams.Publisher<T>	Hooks.addCallSiteInfo(P publisher, java.lang.String callSite) 已过时。 Should only be used by the instrumentation, DOES NOT guarantee any compatibility
static <T,P extends org.reactivestreams.Publisher<T>> org.reactivestreams.Publisher<T>	Hooks.addReturnInfo(P publisher, java.lang.String method) 已过时。 Should only be used by the instrumentation, DOES NOT guarantee any compatibility
O	MonoProcessor.block(java.time.Duration timeout) 已过时。 Block the calling thread for the specified time, waiting for the completion of this MonoProcessor.
static <T> ReplayProcessor<T>	ReplayProcessor.cacheLastOrDefault(T value) 已过时。 use Sinks.many().replay().latestOrDefault(value) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
Mono<T>	Mono.checkpoint(java.lang.String description, boolean forceStackTrace) Activate traceback (full assembly tracing or the lighter assembly marking depending on the forceStackTrace option).
Flux<T>	Flux.checkpoint(java.lang.String description, boolean forceStackTrace) Activate traceback (full assembly tracing or the lighter assembly marking depending on the forceStackTrace option).
Mono<java.util.List<T>>	Flux.collectSortedList(java.util.Comparator<? super T> comparator) 收集元素到集合，自定义排序 Collect all elements emitted by this Flux until this sequence completes, and then sort them using a Comparator into a List that is emitted by the resulting Mono.
void	Operators.MonoSubscriber.complete(O v) Tries to emit the value and complete the underlying subscriber or stores the value away until there is a request for it.
static <T> void	OnNextFailureStrategyTest.drop(java.lang.Throwable e, T v) Helper for other tests to emulate resumeDrop with the public consumer-based API.
static <T> void	OnNextFailureStrategyTest.drop(java.lang.Throwable e, T v) Helper for other tests to emulate resumeDrop with the public consumer-based API.
void	Sinks.One.emitValue(T value, Sinks.EmitFailureHandler failureHandler) A simplified attempt at emitting a non-null element via the Sinks.One.tryEmitValue(Object) API, generating an onNext signal immediately followed by an Subscriber.onComplete() signal.
static Context	Operators.enableOnDiscard(Context target, java.util.function.Consumer<?> discardConsumer) Utility method to activate the onDiscard feature (see Flux.doOnDiscard(Class, Consumer)) in a target Context.
<R> Flux<R>	Flux.flatMap(java.util.function.Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapperOnNext, java.util.function.Function<? super java.lang.Throwable,? extends org.reactivestreams.Publisher<? extends R>> mapperOnError, java.util.function.Supplier<? extends org.reactivestreams.Publisher<? extends R>> mapperOnComplete) Transform the signals emitted by this Flux asynchronously into Publishers, then flatten these inner publishers into a single Flux through merging, which allow them to interleave.
<R> Flux<R>	Flux.flatMap(java.util.function.Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapperOnNext, java.util.function.Function<? super java.lang.Throwable,? extends org.reactivestreams.Publisher<? extends R>> mapperOnError, java.util.function.Supplier<? extends org.reactivestreams.Publisher<? extends R>> mapperOnComplete) Transform the signals emitted by this Flux asynchronously into Publishers, then flatten these inner publishers into a single Flux through merging, which allow them to interleave.
<R> Flux<R>	Flux.flatMap(java.util.function.Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapperOnNext, java.util.function.Function<? super java.lang.Throwable,? extends org.reactivestreams.Publisher<? extends R>> mapperOnError, java.util.function.Supplier<? extends org.reactivestreams.Publisher<? extends R>> mapperOnComplete) Transform the signals emitted by this Flux asynchronously into Publishers, then flatten these inner publishers into a single Flux through merging, which allow them to interleave.
static <T> Mono<T>	Mono.justOrEmpty(java.util.Optional<? extends T> data) 根据 Optional 创建一个Mono，如果值存在就返回一个有元素的Mono，否则就返回一个 Mono.empty() Create a new Mono that emits the specified item if Optional.isPresent() otherwise only emits onComplete.
static <T> Mono<T>	Mono.justOrEmpty(T data) 根据传入的值是否为空来创建一个包含一个元素的Mono或一个 Mono.empty() Create a new Mono that emits the specified item if non null otherwise only emits onComplete.
ParallelFlux<T>	ParallelFlux.log(java.lang.String category) Observe all Reactive Streams signals and use Logger support to handle trace implementation.
Mono<T>	Mono.log(java.lang.String category) Observe all Reactive Streams signals and use Logger support to handle trace implementation.
ParallelFlux<T>	ParallelFlux.log(java.lang.String category, java.util.logging.Level level, boolean showOperatorLine, SignalType... options) Observe Reactive Streams signals matching the passed filter options and use Logger support to handle trace implementation.
Mono<T>	Mono.log(java.lang.String category, java.util.logging.Level level, boolean showOperatorLine, SignalType... options) Observe Reactive Streams signals matching the passed filter options and use Logger support to handle trace implementation.
Flux<T>	Flux.log(java.lang.String category, java.util.logging.Level level, boolean showOperatorLine, SignalType... options) Observe Reactive Streams signals matching the passed filter options and trace them using Logger support.
ParallelFlux<T>	ParallelFlux.log(java.lang.String category, java.util.logging.Level level, SignalType... options) Observe Reactive Streams signals matching the passed filter options and use Logger support to handle trace implementation.
Mono<T>	Mono.log(java.lang.String category, java.util.logging.Level level, SignalType... options) Observe Reactive Streams signals matching the passed flags options and use Logger support to handle trace implementation.
Flux<T>	Flux.log(java.lang.String category, java.util.logging.Level level, SignalType... options) Observe Reactive Streams signals matching the passed filter options and trace them using Logger support.
static <T> void	Operators.onDiscard(T element, Context context) Invoke a (local or global) hook that processes elements that get discarded.
static void	Operators.onDiscardMultiple(java.util.Collection<?> multiple, Context context) Invoke a (local or global) hook that processes elements that get discarded en masse.
static void	Operators.onDiscardMultiple(java.util.Iterator<?> multiple, boolean knownToBeFinite, Context context) Invoke a (local or global) hook that processes elements that remains in an Iterator.
static <T> void	Operators.onDiscardQueueWithClear(java.util.Queue<T> queue, Context context, java.util.function.Function<T,java.util.stream.Stream<?>> extract) Invoke a (local or global) hook that processes elements that get discarded en masse after having been enqueued, due to cancellation or error.
static <T> void	Operators.onDiscardQueueWithClear(java.util.Queue<T> queue, Context context, java.util.function.Function<T,java.util.stream.Stream<?>> extract) Invoke a (local or global) hook that processes elements that get discarded en masse after having been enqueued, due to cancellation or error.
static <T> java.lang.Throwable	Operators.onNextError(T value, java.lang.Throwable error, Context context) Find the OnNextFailureStrategy to apply to the calling async operator (which could be a local error mode defined in the Context) and apply it.
static <T> java.lang.Throwable	Operators.onNextError(T value, java.lang.Throwable error, Context context, org.reactivestreams.Subscription subscriptionForCancel) Find the OnNextFailureStrategy to apply to the calling operator (which could be a local error mode defined in the Context) and apply it.
static <T> java.lang.Throwable	Operators.onNextInnerError(java.lang.Throwable error, Context context, org.reactivestreams.Subscription subscriptionForCancel) Find the OnNextFailureStrategy to apply to the calling operator (which could be a local error mode defined in the Context) and apply it.
static <T> java.lang.RuntimeException	Operators.onNextPollError(T value, java.lang.Throwable error, Context context) Find the OnNextFailureStrategy to apply to the calling async operator (which could be a local error mode defined in the Context) and apply it.
static java.lang.Throwable	Operators.onOperatorError(org.reactivestreams.Subscription subscription, java.lang.Throwable error, Context context) Map an "operator" error given an operator parent Subscription.
static java.lang.Throwable	Operators.onOperatorError(org.reactivestreams.Subscription subscription, java.lang.Throwable error, java.lang.Object dataSignal, Context context) Map an "operator" error given an operator parent Subscription.
static java.lang.Throwable	Operators.onOperatorError(org.reactivestreams.Subscription subscription, java.lang.Throwable error, java.lang.Object dataSignal, Context context) Map an "operator" error given an operator parent Subscription.
static java.lang.RuntimeException	Operators.onRejectedExecution(java.lang.Throwable original, org.reactivestreams.Subscription subscription, java.lang.Throwable suppressed, java.lang.Object dataSignal, Context context) Return a wrapped RejectedExecutionException which can be thrown by the operator.
static java.lang.RuntimeException	Operators.onRejectedExecution(java.lang.Throwable original, org.reactivestreams.Subscription subscription, java.lang.Throwable suppressed, java.lang.Object dataSignal, Context context) Return a wrapped RejectedExecutionException which can be thrown by the operator.
static java.lang.RuntimeException	Operators.onRejectedExecution(java.lang.Throwable original, org.reactivestreams.Subscription subscription, java.lang.Throwable suppressed, java.lang.Object dataSignal, Context context) Return a wrapped RejectedExecutionException which can be thrown by the operator.
void	Operators.MonoSubscriber.setValue(O value) Set the value internally, without impacting request tracking state.
Disposable	ParallelFlux.subscribe(java.util.function.Consumer<? super T> onNext, java.util.function.Consumer<? super java.lang.Throwable> onError) Subscribes to this ParallelFlux by providing an onNext and onError callback and triggers the execution chain for all 'rails'.
Disposable	Mono.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer) Subscribe to this Mono with a Consumer that will consume all the elements in the sequence, as well as a Consumer that will handle errors.
Disposable	Flux.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer) Subscribe to this Flux with a Consumer that will consume all the elements in the sequence, as well as a Consumer that will handle errors.
Disposable	ParallelFlux.subscribe(java.util.function.Consumer<? super T> onNext, java.util.function.Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete) Subscribes to this ParallelFlux by providing an onNext, onError and onComplete callback and triggers the execution chain for all 'rails'.
Disposable	ParallelFlux.subscribe(java.util.function.Consumer<? super T> onNext, java.util.function.Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete) Subscribes to this ParallelFlux by providing an onNext, onError and onComplete callback and triggers the execution chain for all 'rails'.
Disposable	ParallelFlux.subscribe(java.util.function.Consumer<? super T> onNext, java.util.function.Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete) Subscribes to this ParallelFlux by providing an onNext, onError and onComplete callback and triggers the execution chain for all 'rails'.
Disposable	Mono.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer, java.lang.Runnable completeConsumer) Subscribe Consumer to this Mono that will respectively consume all the elements in the sequence, handle errors and react to completion.
Disposable	Mono.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer, java.lang.Runnable completeConsumer) Subscribe Consumer to this Mono that will respectively consume all the elements in the sequence, handle errors and react to completion.
Disposable	Mono.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer, java.lang.Runnable completeConsumer) Subscribe Consumer to this Mono that will respectively consume all the elements in the sequence, handle errors and react to completion.
Disposable	Flux.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer, java.lang.Runnable completeConsumer) Subscribe Consumer to this Flux that will respectively consume all the elements in the sequence, handle errors and react to completion.
Disposable	Flux.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer, java.lang.Runnable completeConsumer) Subscribe Consumer to this Flux that will respectively consume all the elements in the sequence, handle errors and react to completion.
Disposable	Flux.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer, java.lang.Runnable completeConsumer) Subscribe Consumer to this Flux that will respectively consume all the elements in the sequence, handle errors and react to completion.
Disposable	ParallelFlux.subscribe(java.util.function.Consumer<? super T> onNext, java.util.function.Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete, java.util.function.Consumer<? super org.reactivestreams.Subscription> onSubscribe) Subscribes to this ParallelFlux by providing an onNext, onError, onComplete and onSubscribe callback and triggers the execution chain for all 'rails'.
Disposable	ParallelFlux.subscribe(java.util.function.Consumer<? super T> onNext, java.util.function.Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete, java.util.function.Consumer<? super org.reactivestreams.Subscription> onSubscribe) Subscribes to this ParallelFlux by providing an onNext, onError, onComplete and onSubscribe callback and triggers the execution chain for all 'rails'.
Disposable	ParallelFlux.subscribe(java.util.function.Consumer<? super T> onNext, java.util.function.Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete, java.util.function.Consumer<? super org.reactivestreams.Subscription> onSubscribe) Subscribes to this ParallelFlux by providing an onNext, onError, onComplete and onSubscribe callback and triggers the execution chain for all 'rails'.
Disposable	ParallelFlux.subscribe(java.util.function.Consumer<? super T> onNext, java.util.function.Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete, java.util.function.Consumer<? super org.reactivestreams.Subscription> onSubscribe) Subscribes to this ParallelFlux by providing an onNext, onError, onComplete and onSubscribe callback and triggers the execution chain for all 'rails'.
Disposable	Mono.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer, java.lang.Runnable completeConsumer, java.util.function.Consumer<? super org.reactivestreams.Subscription> subscriptionConsumer) Subscribe Consumer to this Mono that will respectively consume all the elements in the sequence, handle errors, react to completion, and request upon subscription.
Disposable	Mono.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer, java.lang.Runnable completeConsumer, java.util.function.Consumer<? super org.reactivestreams.Subscription> subscriptionConsumer) Subscribe Consumer to this Mono that will respectively consume all the elements in the sequence, handle errors, react to completion, and request upon subscription.
Disposable	Mono.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer, java.lang.Runnable completeConsumer, java.util.function.Consumer<? super org.reactivestreams.Subscription> subscriptionConsumer) Subscribe Consumer to this Mono that will respectively consume all the elements in the sequence, handle errors, react to completion, and request upon subscription.
Disposable	Mono.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer, java.lang.Runnable completeConsumer, java.util.function.Consumer<? super org.reactivestreams.Subscription> subscriptionConsumer) Subscribe Consumer to this Mono that will respectively consume all the elements in the sequence, handle errors, react to completion, and request upon subscription.
Disposable	Flux.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer, java.lang.Runnable completeConsumer, java.util.function.Consumer<? super org.reactivestreams.Subscription> subscriptionConsumer) 已过时。 Because users tend to forget to request the subsciption. If the behavior is really needed, consider using Flux.subscribeWith(Subscriber). To be removed in 3.5.
Disposable	Flux.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer, java.lang.Runnable completeConsumer, java.util.function.Consumer<? super org.reactivestreams.Subscription> subscriptionConsumer) 已过时。 Because users tend to forget to request the subsciption. If the behavior is really needed, consider using Flux.subscribeWith(Subscriber). To be removed in 3.5.
Disposable	Flux.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer, java.lang.Runnable completeConsumer, java.util.function.Consumer<? super org.reactivestreams.Subscription> subscriptionConsumer) 已过时。 Because users tend to forget to request the subsciption. If the behavior is really needed, consider using Flux.subscribeWith(Subscriber). To be removed in 3.5.
Disposable	Flux.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer, java.lang.Runnable completeConsumer, java.util.function.Consumer<? super org.reactivestreams.Subscription> subscriptionConsumer) 已过时。 Because users tend to forget to request the subsciption. If the behavior is really needed, consider using Flux.subscribeWith(Subscriber). To be removed in 3.5.
Disposable	ParallelFlux.subscribe(java.util.function.Consumer<? super T> onNext, java.util.function.Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete, Context initialContext) Subscribes to this ParallelFlux by providing an onNext, onError and onComplete callback as well as an initial Context, then trigger the execution chain for all 'rails'.
Disposable	ParallelFlux.subscribe(java.util.function.Consumer<? super T> onNext, java.util.function.Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete, Context initialContext) Subscribes to this ParallelFlux by providing an onNext, onError and onComplete callback as well as an initial Context, then trigger the execution chain for all 'rails'.
Disposable	ParallelFlux.subscribe(java.util.function.Consumer<? super T> onNext, java.util.function.Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete, Context initialContext) Subscribes to this ParallelFlux by providing an onNext, onError and onComplete callback as well as an initial Context, then trigger the execution chain for all 'rails'.
Disposable	ParallelFlux.subscribe(java.util.function.Consumer<? super T> onNext, java.util.function.Consumer<? super java.lang.Throwable> onError, java.lang.Runnable onComplete, Context initialContext) Subscribes to this ParallelFlux by providing an onNext, onError and onComplete callback as well as an initial Context, then trigger the execution chain for all 'rails'.
Disposable	Mono.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer, java.lang.Runnable completeConsumer, Context initialContext) Subscribe Consumer to this Mono that will respectively consume all the elements in the sequence, handle errors and react to completion.
Disposable	Mono.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer, java.lang.Runnable completeConsumer, Context initialContext) Subscribe Consumer to this Mono that will respectively consume all the elements in the sequence, handle errors and react to completion.
Disposable	Mono.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer, java.lang.Runnable completeConsumer, Context initialContext) Subscribe Consumer to this Mono that will respectively consume all the elements in the sequence, handle errors and react to completion.
Disposable	Mono.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer, java.lang.Runnable completeConsumer, Context initialContext) Subscribe Consumer to this Mono that will respectively consume all the elements in the sequence, handle errors and react to completion.
Disposable	Flux.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer, java.lang.Runnable completeConsumer, Context initialContext) Subscribe Consumer to this Flux that will respectively consume all the elements in the sequence, handle errors and react to completion.
Disposable	Flux.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer, java.lang.Runnable completeConsumer, Context initialContext) Subscribe Consumer to this Flux that will respectively consume all the elements in the sequence, handle errors and react to completion.
Disposable	Flux.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer, java.lang.Runnable completeConsumer, Context initialContext) Subscribe Consumer to this Flux that will respectively consume all the elements in the sequence, handle errors and react to completion.
Disposable	Flux.subscribe(java.util.function.Consumer<? super T> consumer, java.util.function.Consumer<? super java.lang.Throwable> errorConsumer, java.lang.Runnable completeConsumer, Context initialContext) Subscribe Consumer to this Flux that will respectively consume all the elements in the sequence, handle errors and react to completion.
void	MonoSink.success(T value) 发布一个消息，消息发布后 MonoSink 会忽略后续消息和异常的发布 Complete this Mono with the given value.
Mono<T>	Mono.timeout(java.time.Duration timeout, Mono<? extends T> fallback, Scheduler timer) 超时设置。
Flux<T>	Flux.timeout(java.time.Duration timeout, org.reactivestreams.Publisher<? extends T> fallback) Switch to a fallback Flux as soon as no item is emitted within the given Duration from the previous emission (or the subscription for the first item).
Flux<T>	Flux.timeout(java.time.Duration timeout, org.reactivestreams.Publisher<? extends T> fallback, Scheduler timer) Switch to a fallback Flux as soon as no item is emitted within the given Duration from the previous emission (or the subscription for the first item), as measured on the specified Scheduler.
java.lang.Iterable<T>	Flux.toIterable(int batchSize, java.util.function.Supplier<java.util.Queue<T>> queueProvider) Transform this Flux into a lazy Iterable blocking on Iterator.next() calls.
Sinks.EmitResult	Sinks.One.tryEmitValue(T value) Try to complete the Mono with an element, generating an onNext signal immediately followed by an onComplete signal.
static boolean	Operators.validate(org.reactivestreams.Subscription current, org.reactivestreams.Subscription next) Check Subscription current state and cancel new Subscription if current is set, or return true if ready to subscribe.

reactor.core.scheduler中Nullable的使用

注释类型为Nullable的reactor.core.scheduler中的方法参数

限定符和类型	方法和说明
static void	Schedulers.resetFrom(Schedulers.Snapshot snapshot) Replace the current Factory and shared Schedulers with the ones saved in a previously captured snapshot.

reactor.test中Nullable的使用

注释类型为Nullable的reactor.test中的方法

限定符和类型	方法和说明
default java.lang.String	ValueFormatters.Extractor.apply(java.lang.Object target, java.util.function.Function<java.lang.Object,java.lang.String> contentFormatter) 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.
Context	StepVerifierOptions.getInitialContext()
java.lang.String	StepVerifierOptions.getScenarioName()
ValueFormatters.ToStringConverter	StepVerifierOptions.getValueFormatter() Get the custom object formatter to use when producing messages.
java.util.function.Supplier<? extends VirtualTimeScheduler>	StepVerifierOptions.getVirtualTimeSchedulerSupplier()

注释类型为Nullable的reactor.test中的方法参数

限定符和类型	方法和说明
default StepVerifier.FirstStep<T>	StepVerifier.FirstStep.enableConditionalSupport(java.util.function.Predicate<? super T> tryOnNextPredicate) Provide a Predicate that will turn this StepVerifier's subscribers into Fuseable.ConditionalSubscriber and drive the Fuseable.ConditionalSubscriber.tryOnNext(Object) behavior of these subscribers.
StepVerifierOptions	StepVerifierOptions.scenarioName(java.lang.String scenarioName) Give a name to the whole scenario tested by the configured StepVerifier.
static void	StepVerifier.setDefaultTimeout(java.time.Duration timeout) Set the StepVerifier.verify() timeout for all StepVerifier created through the factory methods (StepVerifier.create(Publisher), StepVerifier.withVirtualTime(Supplier), etc.).
StepVerifierOptions	StepVerifierOptions.valueFormatter(ValueFormatters.ToStringConverter valueFormatter) Set up a custom value formatter to be used in error messages when presenting expected and actual values.

reactor.test.publisher中Nullable的使用

注释类型为Nullable的reactor.test.publisher中的方法参数

限定符和类型	方法和说明
MonoOperatorTest.Scenario<I,O>	MonoOperatorTest.Scenario.applyAllOptions(OperatorScenario<I,Mono<I>,O,Mono<O>> source)
OperatorScenario<I,PI,O,PO>	OperatorScenario.applyAllOptions(OperatorScenario<I,PI,O,PO> source)
abstract TestPublisher<T>	TestPublisher.next(T value) Send 1 onNext signal to the subscribers.
TestPublisher<T>	TestPublisher.next(T first, T... rest) Send 1-n onNext signals to the subscribers.

reactor.test.subscriber中Nullable的使用

注释类型为Nullable的reactor.test.subscriber中的方法

限定符和类型	方法和说明
Signal<T>	TestSubscriber.getTerminalSignal() Return the terminal Signal if this TestSubscriber TestSubscriber.isTerminated(), or null otherwise.

reactor.util.context中Nullable的使用

注释类型为Nullable的reactor.util.context中的方法

限定符和类型	方法和说明
default <T> T	ContextView.getOrDefault(java.lang.Object key, T defaultValue) Resolve a value given a key within the Context.
<T> T	ReactorContextAccessor.readValue(ContextView sourceContext, java.lang.Object key)

注释类型为Nullable的reactor.util.context中的方法参数

限定符和类型	方法和说明
default <T> T	ContextView.getOrDefault(java.lang.Object key, T defaultValue) Resolve a value given a key within the Context.
default Context	Context.putNonNull(java.lang.Object key, java.lang.Object valueOrNull) Create a new Context that contains all current key/value pairs plus the given key/value pair only if the value is not null.

reactor.util.function中Nullable的使用

注释类型为Nullable的reactor.util.function中的方法

限定符和类型	方法和说明
java.lang.Object	Tuple5.get(int index)
java.lang.Object	Tuple4.get(int index)
java.lang.Object	Tuple8.get(int index)
java.lang.Object	Tuple3.get(int index)
java.lang.Object	Tuple6.get(int index)
java.lang.Object	Tuple2.get(int index) Get the object at the given index.
java.lang.Object	Tuple7.get(int index)

注释类型为Nullable的reactor.util.function中的方法参数

限定符和类型	方法和说明
boolean	Tuple5.equals(java.lang.Object o)
boolean	Tuple4.equals(java.lang.Object o)
boolean	Tuple8.equals(java.lang.Object o)
boolean	Tuple3.equals(java.lang.Object o)
boolean	Tuple6.equals(java.lang.Object o)
boolean	Tuple2.equals(java.lang.Object o)
boolean	Tuple7.equals(java.lang.Object o)

reactor.util.retry中Nullable的使用

注释类型为Nullable的reactor.util.retry中的方法参数

限定符和类型	方法和说明
RetryBackoffSpec	RetryBackoffSpec.scheduler(Scheduler backoffScheduler) Set a Scheduler on which to execute the delays computed by the exponential backoff strategy.