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)