RxJava 3 3.1.8 · io.reactivex.rxjava3.internal.subscriptions

Class Summary

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

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