Uses of Class
io.reactivex.rxjava3.internal.operators.observable.ObservableReplay.ReplayObserver
Packages that use ObservableReplay.ReplayObserver
-
Uses of ObservableReplay.ReplayObserver in io.reactivex.rxjava3.internal.operators.observable
Fields in io.reactivex.rxjava3.internal.operators.observable declared as ObservableReplay.ReplayObserverModifier and TypeFieldDescription(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.ReplayObserverModifier and TypeFieldDescriptionprivate 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.ReplayObserverModifierConstructorDescription(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.ReplayObserverModifierConstructorDescriptionprivate
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)