Uses of Class
io.reactivex.rxjava3.internal.operators.observable.ObservableReplay.ReplayObserver

Packages that use ObservableReplay.ReplayObserver

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

Uses of ObservableReplay.ReplayObserver in io.reactivex.rxjava3.internal.operators.observable

Fields in io.reactivex.rxjava3.internal.operators.observable declared as ObservableReplay.ReplayObserver

Modifier and Type	Field	Description
(package private) final ObservableReplay.ReplayObserver<T>	ObservableReplay.InnerDisposable.parent	The parent subscriber-to-source used to allow removing the child in case of child dispose() call.

Fields in io.reactivex.rxjava3.internal.operators.observable with type parameters of type ObservableReplay.ReplayObserver

Modifier and Type	Field	Description
private final AtomicReference<ObservableReplay.ReplayObserver<T>>	ObservableReplay.ReplaySource.curr
(package private) final AtomicReference<ObservableReplay.ReplayObserver<T>>	ObservableReplay.current	Holds the current subscriber that is, will be or just was subscribed to the source observable.
(package private) final AtomicReference<ObservableReplay.ReplayObserver<T>>	ObservableReplay.ReplayObserver.current	The current connection.

Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type ObservableReplay.ReplayObserver

Modifier	Constructor	Description
(package private)	InnerDisposable(ObservableReplay.ReplayObserver<T> parent, Observer<? super T> child)

Constructor parameters in io.reactivex.rxjava3.internal.operators.observable with type arguments of type ObservableReplay.ReplayObserver

Modifier	Constructor	Description
private	ObservableReplay(ObservableSource<T> onSubscribe, ObservableSource<T> source, AtomicReference<ObservableReplay.ReplayObserver<T>> current, ObservableReplay.BufferSupplier<T> bufferFactory)
(package private)	ReplayObserver(ObservableReplay.ReplayBuffer<T> buffer, AtomicReference<ObservableReplay.ReplayObserver<T>> current)
(package private)	ReplaySource(AtomicReference<ObservableReplay.ReplayObserver<T>> curr, ObservableReplay.BufferSupplier<T> bufferFactory)