Uses of Interface
io.reactivex.rxjava3.internal.operators.observable.ObservableReplay.BufferSupplier
-
Packages that use ObservableReplay.BufferSupplier Package Description io.reactivex.rxjava3.internal.operators.observable -
-
Uses of ObservableReplay.BufferSupplier in io.reactivex.rxjava3.internal.operators.observable
Classes in io.reactivex.rxjava3.internal.operators.observable that implement ObservableReplay.BufferSupplier Modifier and Type Class Description (package private) static class
ObservableReplay.ReplayBufferSupplier<T>
(package private) static class
ObservableReplay.ScheduledReplaySupplier<T>
(package private) static class
ObservableReplay.UnBoundedFactory
Fields in io.reactivex.rxjava3.internal.operators.observable declared as ObservableReplay.BufferSupplier Modifier and Type Field Description (package private) ObservableReplay.BufferSupplier<T>
ObservableReplay. bufferFactory
A factory that creates the appropriate buffer for the ReplayObserver.private ObservableReplay.BufferSupplier<T>
ObservableReplay.ReplaySource. bufferFactory
(package private) static ObservableReplay.BufferSupplier
ObservableReplay. DEFAULT_UNBOUNDED_FACTORY
Methods in io.reactivex.rxjava3.internal.operators.observable with parameters of type ObservableReplay.BufferSupplier Modifier and Type Method Description (package private) static <T> ConnectableObservable<T>
ObservableReplay. create(ObservableSource<T> source, ObservableReplay.BufferSupplier<T> bufferFactory)
Creates a OperatorReplay instance to replay values of the given source observable.Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type ObservableReplay.BufferSupplier Constructor Description ObservableReplay(ObservableSource<T> onSubscribe, ObservableSource<T> source, java.util.concurrent.atomic.AtomicReference<ObservableReplay.ReplayObserver<T>> current, ObservableReplay.BufferSupplier<T> bufferFactory)
ReplaySource(java.util.concurrent.atomic.AtomicReference<ObservableReplay.ReplayObserver<T>> curr, ObservableReplay.BufferSupplier<T> bufferFactory)
-