Package io.reactivex.rxjava3.internal.operators.observable

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>, java.io.Serializable, java.lang.Runnable

Enclosing class:

ObservableRefCount<T>

static final class ObservableRefCount.RefConnection
extends java.util.concurrent.atomic.AtomicReference<Disposable>
implements java.lang.Runnable, Consumer<Disposable>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	connected
(package private) boolean	disconnectedEarly
(package private) ObservableRefCount<?>	parent
private static long	serialVersionUID
(package private) long	subscriberCount
(package private) Disposable	timer

Constructor Summary

Constructors

Constructor	Description
RefConnection(ObservableRefCount<?> parent)

Method Summary

Modifier and Type	Method	Description
void	accept(Disposable t)	Consume the given value.
void	run()

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

parent

final ObservableRefCount<?> parent

timer

Disposable timer

subscriberCount

long subscriberCount

connected

boolean connected

disconnectedEarly

boolean disconnectedEarly

Constructor Detail

RefConnection

RefConnection(ObservableRefCount<?> parent)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

accept

public void accept(Disposable t)

Description copied from interface: Consumer

Consume the given value.

Specified by:

accept in interface Consumer<Disposable>

Parameters:

t - the value