Uses of Class
io.reactivex.rxjava3.internal.operators.observable.ObservableReplay.InnerDisposable
Packages that use ObservableReplay.InnerDisposable
-
Uses of ObservableReplay.InnerDisposable in io.reactivex.rxjava3.internal.operators.observable
Fields in io.reactivex.rxjava3.internal.operators.observable declared as ObservableReplay.InnerDisposableModifier and TypeFieldDescription(package private) static final ObservableReplay.InnerDisposable[]
ObservableReplay.ReplayObserver.EMPTY
Indicates an empty array of inner observers.(package private) static final ObservableReplay.InnerDisposable[]
ObservableReplay.ReplayObserver.TERMINATED
Indicates a terminated ReplayObserver.Methods in io.reactivex.rxjava3.internal.operators.observable with parameters of type ObservableReplay.InnerDisposableModifier and TypeMethodDescription(package private) boolean
ObservableReplay.ReplayObserver.add
(ObservableReplay.InnerDisposable<T> producer) Atomically try adding a new InnerDisposable to this Observer or return false if this Observer was terminated.(package private) void
ObservableReplay.ReplayObserver.remove
(ObservableReplay.InnerDisposable<T> producer) Atomically removes the given InnerDisposable from the observers array.final void
ObservableReplay.BoundedReplayBuffer.replay
(ObservableReplay.InnerDisposable<T> output) void
ObservableReplay.ReplayBuffer.replay
(ObservableReplay.InnerDisposable<T> output) Tries to replay the buffered values to the subscriber inside the output if there is new value and requests available at the same time.void
ObservableReplay.UnboundedReplayBuffer.replay
(ObservableReplay.InnerDisposable<T> output)