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