类的使用
reactor.core.publisher.UnicastProcessor

使用UnicastProcessor的程序包

程序包	说明
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.publisher中UnicastProcessor的使用

返回UnicastProcessor的reactor.core.publisher中的方法

限定符和类型	方法和说明
static <E> UnicastProcessor<E>	UnicastProcessor.create() 已过时。 use Sinks.many().unicast().onBackpressureBuffer() (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
static <E> UnicastProcessor<E>	UnicastProcessor.create(java.util.Queue<E> queue) 已过时。 use Sinks.many().unicast().onBackpressureBuffer(queue) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
static <E> UnicastProcessor<E>	UnicastProcessor.create(java.util.Queue<E> queue, java.util.function.Consumer<? super E> onOverflow, Disposable endcallback) 已过时。 use Sinks.many().unicast().onBackpressureBuffer(queue, endCallback) (or the unsafe variant if you're sure about external synchronization). The onOverflow callback is not supported anymore. To be removed in 3.5.
static <E> UnicastProcessor<E>	UnicastProcessor.create(java.util.Queue<E> queue, Disposable endcallback) 已过时。 use Sinks.many().unicast().onBackpressureBuffer(queue, endCallback) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.