MonoSink (reactor-3)

类型参数:

T - the value type emitted
```
public interface MonoSink<T>
```
Wrapper API around an actual downstream Subscriber for emitting nothing, a single value or an error (mutually exclusive).

方法概要

所有方法实例方法抽象方法默认方法已过时的方法
限定符和类型	方法和说明
`default ContextView`	`contextView()` Return the current subscriber's context as a `ContextView` for inspection.
`Context`	`currentContext()` 已过时。 To be removed in 3.6.0 at the earliest. Prefer using #getContextView() instead.
`void`	`error(java.lang.Throwable e)` 抛出一个异常。
`MonoSink<T>`	`onCancel(Disposable d)` 取消订阅事件，调用`Subscription.cancel()`方法触发，多次注册以最后一次为准，当元素发布后再调用取消订阅时不生效 Attach a `Disposable` as a callback for when this `MonoSink` is cancelled.
`MonoSink<T>`	`onDispose(Disposable d)` 在完成时，在发生异常时(onComplete, onError)，在Subscription调用`Subscription.cancel()`方法取消时触发，可重复注册 Attach a `Disposable` as a callback for when this `MonoSink` is effectively disposed, that is it cannot be used anymore.
`MonoSink<T>`	`onRequest(java.util.function.LongConsumer consumer)` 请求事件，订阅者订阅后发起请求数据时触发，会传入一个Long型的背压数，默认是Long.MAX_VALUE Attaches a `LongConsumer` to this `MonoSink` that will be notified of any request to this sink.
`void`	`success()` 发布一个空消息。
`void`	`success(T value)` 发布一个消息，消息发布后 MonoSink 会忽略后续消息和异常的发布 Complete this `Mono` with the given value.

- 方法详细资料
  - success
```
void success()
```
    发布一个空消息。消息发布后 MonoSink 会忽略后续消息和异常的发布
    Complete without any value.
    Calling this method multiple times or after the other terminating methods has no effect.
  - success
```
void success(@Nullable
             T value)
```
    发布一个消息，消息发布后 MonoSink 会忽略后续消息和异常的发布
    Complete this Mono with the given value.
    Calling this method multiple times or after the other terminating methods has no effect (the value is dropped). Calling this method with a null value will be silently accepted as a call to success() by standard implementations.
    
    参数:
    
    value - the value to complete with
  - error
```
void error(java.lang.Throwable e)
```
    抛出一个异常。MonoSink 抛出一个异常后会忽略后续异常抛出和消息发布
    Terminate with the given exception
    Calling this method multiple times or after the other terminating methods is an unsupported operation. It will discard the exception through the Hooks.onErrorDropped(Consumer) hook. This is to avoid complete and silent swallowing of the exception.
    
    参数:
    
    e - the exception to complete with
  - currentContext
```
@Deprecated
Context currentContext()
```
    已过时。 To be removed in 3.6.0 at the earliest. Prefer using #getContextView() instead.
    
    Return the current subscriber Context.
    Context can be enriched via Mono.contextWrite(Function) operator or directly by a child subscriber overriding CoreSubscriber.currentContext()
  - contextView
```
default ContextView contextView()
```
    Return the current subscriber's context as a ContextView for inspection.
    Context can be enriched downstream via Mono.contextWrite(Function) operator or directly by a child subscriber overriding CoreSubscriber.currentContext().
    
    返回:
    
    the current subscriber ContextView.
  - onRequest
```
MonoSink<T> onRequest(java.util.function.LongConsumer consumer)
```
    请求事件，订阅者订阅后发起请求数据时触发，会传入一个Long型的背压数，默认是Long.MAX_VALUE
    Attaches a LongConsumer to this MonoSink that will be notified of any request to this sink.
    
    参数:
    
    consumer - the consumer to invoke on request
    
    返回:
    
    MonoSink with a consumer that is notified of requests
  - onCancel
```
MonoSink<T> onCancel(Disposable d)
```
    取消订阅事件，调用Subscription.cancel()方法触发，多次注册以最后一次为准，当元素发布后再调用取消订阅时不生效
    Attach a Disposable as a callback for when this MonoSink is cancelled. At most one callback can be registered, and subsequent calls to this method will result in the immediate disposal of the extraneous Disposable.
    The callback is only relevant when the downstream Subscription is cancelled.
    
    参数:
    
    d - the Disposable to use as a callback
    
    返回:
    
    the MonoSink with a cancellation callback
    
    另请参阅:
    
    onDispose(Disposable) for a callback that covers cancellation AND terminal signals
  - onDispose
```
MonoSink<T> onDispose(Disposable d)
```
    在完成时，在发生异常时(onComplete, onError)，在Subscription调用Subscription.cancel()方法取消时触发，可重复注册
    Attach a Disposable as a callback for when this MonoSink is effectively disposed, that is it cannot be used anymore. This includes both having played terminal signals (onComplete, onError) and having been cancelled (see onCancel(Disposable)). At most one callback can be registered, and subsequent calls to this method will result in the immediate disposal of the extraneous Disposable.
    Note that the "dispose" term is used from the perspective of the sink. Not to be confused with Mono.subscribe()'s Disposable.dispose() method, which maps to disposing the Subscription (effectively, a Subscription.cancel() signal).
    
    参数:
    
    d - the Disposable to use as a callback
    
    返回:
    
    the MonoSink with a callback invoked on any terminal signal or on cancellation
    
    另请参阅:
    
    onCancel(Disposable) for a cancellation-only callback

接口 MonoSink<T>

方法概要

方法详细资料

success

success

error

currentContext

contextView

onRequest

onCancel

onDispose