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) 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 java.util.concurrent.atomic.AtomicReference<ObservableReplay.ReplayObserver<T>>
ObservableReplay.ReplaySource. curr
(package private) java.util.concurrent.atomic.AtomicReference<ObservableReplay.ReplayObserver<T>>
ObservableReplay. current
Holds the current subscriber that is, will be or just was subscribed to the source observable.(package private) java.util.concurrent.atomic.AtomicReference<ObservableReplay.ReplayObserver<T>>
ObservableReplay.ReplayObserver. current
The current connection.Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type ObservableReplay.ReplayObserver Constructor Description 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 Constructor Description ObservableReplay(ObservableSource<T> onSubscribe, ObservableSource<T> source, java.util.concurrent.atomic.AtomicReference<ObservableReplay.ReplayObserver<T>> current, ObservableReplay.BufferSupplier<T> bufferFactory)
ReplayObserver(ObservableReplay.ReplayBuffer<T> buffer, java.util.concurrent.atomic.AtomicReference<ObservableReplay.ReplayObserver<T>> current)
ReplaySource(java.util.concurrent.atomic.AtomicReference<ObservableReplay.ReplayObserver<T>> curr, ObservableReplay.BufferSupplier<T> bufferFactory)
-