Uses of Interface
reactor.core.Fuseable.QueueSubscription

Packages that use Fuseable.QueueSubscription

Package	Description
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.

Uses of Fuseable.QueueSubscription in reactor.core

Subinterfaces of Fuseable.QueueSubscription in reactor.core

Modifier and Type	Interface and Description
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.

Uses of Fuseable.QueueSubscription in reactor.core.publisher

Classes in reactor.core.publisher that implement Fuseable.QueueSubscription

Modifier and Type	Class and Description
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> Deprecated. to be removed in 3.5, prefer clear cut usage of Sinks through variations under Sinks.many().unicast().

Methods in reactor.core.publisher that return Fuseable.QueueSubscription

Modifier and Type	Method and Description
static <T> Fuseable.QueueSubscription<T>	Operators.as(Subscription s) Returns the subscription as QueueSubscription if possible or null.