| Class | Description |
|---|---|
| AsyncSubscription |
A subscription implementation that arbitrates exactly one other Subscription and can
hold a single disposable resource.
|
| BooleanSubscription |
Subscription implementation that ignores request but remembers the cancellation
which can be checked via isCancelled.
|
| DisposableSubscription |
Subscription that ignores (but validates) requests and delegates cancel to a disposable instance.
|
| FullArbiter<T> |
Performs full arbitration of Subscriber events with strict drain (i.e., old emissions of another
subscriber are dropped).
|
| ScalarAsyncSubscription<T> |
A Subscription that coordinates the emission of a single value set asynchronously.
|
| ScalarSubscription<T> |
A Subscription that holds a constant value and emits it only when requested.
|
| SubscriptionArbiter |
Arbitrates requests and cancellation between Subscriptions.
|
| Enum | Description |
|---|---|
| EmptySubscription |
An empty subscription that does nothing other than validates the request amount.
|
| SubscriptionHelper |
Utility methods to validate Subscriptions and Disposables in the various onSubscribe calls.
|