Flux by calling a biconsumer with the
output sink for each onNext.BiConsumer 来处理此Mono发出的项目，相比与 Mono.map(Function),
它可以往Sink里传递 SynchronousSink.error(Throwable) 或 SynchronousSink.complete()
Handle the items emitted by this Mono by calling a biconsumer with the
output sink for each onNext.discard hook, in any order.discard hook.discard hook,
and check that the collection of discarded elements matches a predicate.discard hook, and assert them as a collection.discard hook,
in any order, and that no other elements were dropped.Subscriber is actively subscribedSubscriber is actively subscribedHooks.onNextDropped(Consumer) hook, in any order.Hooks.onNextDropped(Consumer) hook.Hooks.onErrorDropped(Consumer) hook.Hooks.onErrorDropped(Consumer) hook.Hooks.onErrorDropped(Consumer) hook.Hooks.onErrorDropped(Consumer) hook.Hooks.onErrorDropped(Consumer) hook, and check that the collection of
errors matches a predicate.Hooks.onErrorDropped(Consumer) hook, and assert them as a collection.Hooks.onErrorDropped(Consumer) hook.Hooks.onErrorDropped(Consumer) hook.Hooks.onNextDropped(Consumer) hook, in any order, and that no
other elements were dropped.Flux sequence is
equal to the provided value.Mono has an element.Flux sequence has at least one element.Context contains a value for the given key.Context.discard hook.Hooks.onNextDropped(Consumer) hook.Hooks.onErrorDropped(Consumer) hook.onOperatorError hook
exactly once and the error matches the given predicate.onOperatorError hook
exactly once and the error is of the given type.onOperatorError hook
at least once.onOperatorError hook
exactly n times.onOperatorError hook
once or more, and check that the collection of errors and their optionally
associated data matches a predicate.onOperatorError hook
once or more, and assert the errors and optionally associated data as a collection.onOperatorError hook
exactly once and the error has the exact provided message.onOperatorError hook
exactly once, with the error message containing the provided string.Context is of the given size.Flux instance.Mono instance.ParallelFlux and its Subscription
as well.