接口的使用
reactor.core.Fuseable.QueueSubscription

使用Fuseable.QueueSubscription的程序包

程序包	说明
reactor.core	Core components of the framework supporting extensions to the Reactive Stream programming model.
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中Fuseable.QueueSubscription的使用

reactor.core中Fuseable.QueueSubscription的子接口

限定符和类型	接口和说明
static interface	Fuseable.SynchronousSubscription<T> Base class for synchronous sources which have fixed size and can emit their items in a pull fashion, thus avoiding the request-accounting overhead in many cases.

reactor.core.publisher中Fuseable.QueueSubscription的使用

实现Fuseable.QueueSubscription的reactor.core.publisher中的类

限定符和类型	类和说明
static class	Operators.MonoSubscriber<I,O> A Subscriber/Subscription barrier that holds a single value at most and properly gates asynchronous behaviors resulting from concurrent request or cancel and onXXX signals.
class	UnicastProcessor<T> 已过时。 to be removed in 3.5, prefer clear cut usage of Sinks through variations under Sinks.many().unicast().

返回Fuseable.QueueSubscription的reactor.core.publisher中的方法

限定符和类型	方法和说明
static <T> Fuseable.QueueSubscription<T>	Operators.as(org.reactivestreams.Subscription s) Returns the subscription as QueueSubscription if possible or null.