Package io.reactivex.rxjava3.internal.subscriptions

Class Summary

Class	Description
ArrayCompositeSubscription	A composite disposable with a fixed number of slots.
AsyncSubscription	A subscription implementation that arbitrates exactly one other Subscription and can hold a single disposable resource.
BasicIntQueueSubscription<T>	Base class extending AtomicInteger (wip or request accounting) and QueueSubscription (fusion).
BasicQueueSubscription<T>	Base class extending AtomicLong (wip or request accounting) and QueueSubscription (fusion).
BooleanSubscription	Subscription implementation that ignores request but remembers the cancellation which can be checked via isCancelled.
DeferredScalarSubscription<T>	A subscription that signals a single value eventually.
ScalarSubscription<T>	A Subscription that holds a constant value and emits it only when requested.
SubscriptionArbiter	Arbitrates requests and cancellation between Subscriptions.

Enum Summary

Enum	Description
EmptySubscription	An empty subscription that does nothing other than validates the request amount.
SubscriptionHelper	Utility methods to validate Subscriptions in the various onSubscribe calls.