Uses of Class
io.reactivex.rxjava3.internal.operators.observable.ObservablePublish.PublishConnection

Packages that use ObservablePublish.PublishConnection

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

Uses of ObservablePublish.PublishConnection in io.reactivex.rxjava3.internal.operators.observable

Subclasses with type arguments of type ObservablePublish.PublishConnection in io.reactivex.rxjava3.internal.operators.observable

Modifier and Type	Class	Description
(package private) static final class	ObservablePublish.InnerDisposable<T>	Intercepts the dispose signal from the downstream and removes itself from the connection's observers array at most once.

Fields in io.reactivex.rxjava3.internal.operators.observable with type parameters of type ObservablePublish.PublishConnection

Modifier and Type	Field	Description
(package private) final AtomicReference<ObservablePublish.PublishConnection<T>>	ObservablePublish.current
(package private) final AtomicReference<ObservablePublish.PublishConnection<T>>	ObservablePublish.PublishConnection.current

Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type ObservablePublish.PublishConnection

Modifier	Constructor	Description
(package private)	InnerDisposable(Observer<? super T> downstream, ObservablePublish.PublishConnection<T> parent)

Constructor parameters in io.reactivex.rxjava3.internal.operators.observable with type arguments of type ObservablePublish.PublishConnection

Modifier	Constructor	Description
(package private)	PublishConnection(AtomicReference<ObservablePublish.PublishConnection<T>> current)