接口的使用
reactor.core.publisher.Sinks.ManyWithUpstream

使用Sinks.ManyWithUpstream的程序包

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

实现Sinks.ManyWithUpstream的reactor.core.publisher中的类

限定符和类型

类和说明

class

EmitterProcessor<T> 已过时。 To be removed in 3.5. Prefer clear cut usage of Sinks through variations of Sinks.many().multicast().onBackpressureBuffer(). If you really need the subscribe-to-upstream functionality of a Processor, switch to Sinks.ManyWithUpstream with Sinks.unsafe() variants of Sinks.unsafe().manyWithUpstream(). This processor was blocking in EmitterProcessor.onNext(Object). This behaviour can be implemented with the Sinks API by calling Sinks.Many.tryEmitNext(Object) and retrying, e.g.: while (sink.tryEmitNext(v).hasFailed()) { LockSupport.parkNanos(10); }

返回Sinks.ManyWithUpstream的reactor.core.publisher中的方法

限定符和类型	方法和说明
<T> Sinks.ManyWithUpstream<T>	Sinks.ManyWithUpstreamUnsafeSpec.multicastOnBackpressureBuffer() A Sinks.ManyWithUpstream with the following characteristics: Multicast Without Subscriber: warm up.
<T> Sinks.ManyWithUpstream<T>	Sinks.ManyWithUpstreamUnsafeSpec.multicastOnBackpressureBuffer(int bufferSize, boolean autoCancel) A Sinks.ManyWithUpstream with the following characteristics: Multicast Without Subscriber: warm up.