Package io.reactivex.rxjava3.internal.subscriptions


package io.reactivex.rxjava3.internal.subscriptions
  • Class
    Description
    A composite disposable with a fixed number of slots.
    A subscription implementation that arbitrates exactly one other Subscription and can hold a single disposable resource.
    Base class extending AtomicInteger (wip or request accounting) and QueueSubscription (fusion).
    Base class extending AtomicLong (wip or request accounting) and QueueSubscription (fusion).
    Subscription implementation that ignores request but remembers the cancellation which can be checked via isCancelled.
    A subscription that signals a single value eventually.
    An empty subscription that does nothing other than validates the request amount.
    A Subscription that holds a constant value and emits it only when requested.
    Arbitrates requests and cancellation between Subscriptions.
    Utility methods to validate Subscriptions in the various onSubscribe calls.