Sinks.UnicastSpec (reactor-3)

封闭类:

Sinks
```
public static interface Sinks.UnicastSpec
```
Provides unicast: 1 sink, 1 Subscriber

方法概要

所有方法实例方法抽象方法
限定符和类型	方法和说明
`<T> Sinks.Many<T>`	`onBackpressureBuffer()` A `Sinks.Many` with the following characteristics: Unicast: contrary to most other `Sinks.Many`, the `Flux` view rejects `subscribers` past the first one.
`<T> Sinks.Many<T>`	`onBackpressureBuffer(java.util.Queue<T> queue)` A `Sinks.Many` with the following characteristics: Unicast: contrary to most other `Sinks.Many`, the `Flux` view rejects `subscribers` past the first one.
`<T> Sinks.Many<T>`	`onBackpressureBuffer(java.util.Queue<T> queue, Disposable endCallback)` A `Sinks.Many` with the following characteristics: Unicast: contrary to most other `Sinks.Many`, the `Flux` view rejects `subscribers` past the first one.
`<T> Sinks.Many<T>`	`onBackpressureError()` A `Sinks.Many` with the following characteristics: Unicast: contrary to most other `Sinks.Many`, the `Flux` view rejects `subscribers` past the first one.

- 方法详细资料
  - onBackpressureBuffer
```
<T> Sinks.Many<T> onBackpressureBuffer()
```
    A Sinks.Many with the following characteristics:
    - Unicast: contrary to most other Sinks.Many, the Flux view rejects subscribers past the first one.
    - Backpressure : this sink honors downstream demand of its single Subscriber.
    - Replaying: non-applicable, since only one Subscriber can register.
    - Without Subscriber: all elements pushed to this sink are remembered and will be replayed once the Subscriber subscribes.
  - onBackpressureBuffer
```
<T> Sinks.Many<T> onBackpressureBuffer(java.util.Queue<T> queue)
```
    A Sinks.Many with the following characteristics:
    - Unicast: contrary to most other Sinks.Many, the Flux view rejects subscribers past the first one.
    - Backpressure : this sink honors downstream demand of its single Subscriber.
    - Replaying: non-applicable, since only one Subscriber can register.
    - Without Subscriber: depending on the queue, all elements pushed to this sink are remembered and will be replayed once the Subscriber subscribes.
    参数:
    
    queue - an arbitrary queue to use that must at least support Single Producer / Single Consumer semantics
  - onBackpressureBuffer
```
<T> Sinks.Many<T> onBackpressureBuffer(java.util.Queue<T> queue,
                                       Disposable endCallback)
```
    A Sinks.Many with the following characteristics:
    - Unicast: contrary to most other Sinks.Many, the Flux view rejects subscribers past the first one.
    - Backpressure : this sink honors downstream demand of its single Subscriber.
    - Replaying: non-applicable, since only one Subscriber can register.
    - Without Subscriber: depending on the queue, all elements pushed to this sink are remembered and will be replayed once the Subscriber subscribes.
    参数:
    
    queue - an arbitrary queue to use that must at least support Single Producer / Single Consumer semantics
    
    endCallback - when a terminal signal is observed: error, complete or cancel
  - onBackpressureError
```
<T> Sinks.Many<T> onBackpressureError()
```
    A Sinks.Many with the following characteristics:
    - Unicast: contrary to most other Sinks.Many, the Flux view rejects subscribers past the first one.
    - Backpressure : this sink honors downstream demand of the Subscriber, and will emit Subscriber.onError(Throwable) if there is a mismatch.
    - Replaying: No replay. Only forwards to a Subscriber the elements that have been pushed to the sink AFTER this subscriber was subscribed.

接口 Sinks.UnicastSpec

方法概要

方法详细资料

onBackpressureBuffer

onBackpressureBuffer

onBackpressureBuffer

onBackpressureError