Class ObservableRefCount.RefConnection

java.lang.Object
java.util.concurrent.atomic.AtomicReference<Disposable>
io.reactivex.rxjava3.internal.operators.observable.ObservableRefCount.RefConnection
All Implemented Interfaces:
Consumer<Disposable>, Serializable, Runnable
Enclosing class:
ObservableRefCount<T>

static final class ObservableRefCount.RefConnection extends AtomicReference<Disposable> implements Runnable, Consumer<Disposable>
  • Field Details

    • serialVersionUID

      private static final long serialVersionUID
      See Also:
    • parent

      final ObservableRefCount<?> parent
    • timer

      Disposable timer
    • subscriberCount

      long subscriberCount
    • connected

      boolean connected
    • disconnectedEarly

      boolean disconnectedEarly
  • Constructor Details

  • Method Details