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 Summary
FieldsModifier and TypeFieldDescription(package private) boolean
(package private) boolean
(package private) final ObservableRefCount
<?> private static final long
(package private) long
(package private) Disposable
-
Constructor Summary
Constructors -
Method Summary
Methods inherited from class java.util.concurrent.atomic.AtomicReference
accumulateAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, get, getAcquire, getAndAccumulate, getAndSet, getAndUpdate, getOpaque, getPlain, lazySet, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
parent
-
timer
Disposable timer -
subscriberCount
long subscriberCount -
connected
boolean connected -
disconnectedEarly
boolean disconnectedEarly
-
-
Constructor Details
-
RefConnection
RefConnection(ObservableRefCount<?> parent)
-
-
Method Details