Uses of Class
io.reactivex.rxjava3.internal.operators.observable.ObservableReplay.InnerDisposable
-
Packages that use ObservableReplay.InnerDisposable Package Description io.reactivex.rxjava3.internal.operators.observable -
-
Uses of ObservableReplay.InnerDisposable in io.reactivex.rxjava3.internal.operators.observable
Fields in io.reactivex.rxjava3.internal.operators.observable declared as ObservableReplay.InnerDisposable Modifier and Type Field Description (package private) static ObservableReplay.InnerDisposable[]ObservableReplay.ReplayObserver. EMPTYIndicates an empty array of inner observers.(package private) static ObservableReplay.InnerDisposable[]ObservableReplay.ReplayObserver. TERMINATEDIndicates a terminated ReplayObserver.Methods in io.reactivex.rxjava3.internal.operators.observable with parameters of type ObservableReplay.InnerDisposable Modifier and Type Method Description (package private) booleanObservableReplay.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) voidObservableReplay.ReplayObserver. remove(ObservableReplay.InnerDisposable<T> producer)Atomically removes the given InnerDisposable from the observers array.voidObservableReplay.BoundedReplayBuffer. replay(ObservableReplay.InnerDisposable<T> output)voidObservableReplay.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.voidObservableReplay.UnboundedReplayBuffer. replay(ObservableReplay.InnerDisposable<T> output)
-