Uses of Interface
io.reactivex.rxjava3.internal.operators.flowable.FlowableReplay.ReplayBuffer

Packages that use FlowableReplay.ReplayBuffer

Package	Description
io.reactivex.rxjava3.internal.operators.flowable

Uses of FlowableReplay.ReplayBuffer in io.reactivex.rxjava3.internal.operators.flowable

Classes in io.reactivex.rxjava3.internal.operators.flowable that implement FlowableReplay.ReplayBuffer

Modifier and Type	Class	Description
(package private) static class	FlowableReplay.BoundedReplayBuffer<T>	Base class for bounded buffering with options to specify an enter and leave transforms and custom truncation behavior.
(package private) static final class	FlowableReplay.SizeAndTimeBoundReplayBuffer<T>	Size and time bound replay buffer.
(package private) static final class	FlowableReplay.SizeBoundReplayBuffer<T>	A bounded replay buffer implementation with size limit only.
(package private) static final class	FlowableReplay.UnboundedReplayBuffer<T>	Holds an unbounded list of events.

Classes in io.reactivex.rxjava3.internal.operators.flowable that implement interfaces with type arguments of type FlowableReplay.ReplayBuffer

Modifier and Type	Class	Description
(package private) static final class	FlowableReplay.ReplayBufferSupplier<T>
(package private) static final class	FlowableReplay.ScheduledReplayBufferSupplier<T>

Fields in io.reactivex.rxjava3.internal.operators.flowable declared as FlowableReplay.ReplayBuffer

Modifier and Type	Field	Description
(package private) final FlowableReplay.ReplayBuffer<T>	FlowableReplay.ReplaySubscriber.buffer	Holds notifications from upstream.

Fields in io.reactivex.rxjava3.internal.operators.flowable with type parameters of type FlowableReplay.ReplayBuffer

Modifier and Type	Field	Description
(package private) final Supplier<? extends FlowableReplay.ReplayBuffer<T>>	FlowableReplay.bufferFactory	A factory that creates the appropriate buffer for the ReplaySubscriber.
private final Supplier<? extends FlowableReplay.ReplayBuffer<T>>	FlowableReplay.ReplayPublisher.bufferFactory

Methods in io.reactivex.rxjava3.internal.operators.flowable that return FlowableReplay.ReplayBuffer

Modifier and Type	Method	Description
FlowableReplay.ReplayBuffer<T>	FlowableReplay.ReplayBufferSupplier.get()
FlowableReplay.ReplayBuffer<T>	FlowableReplay.ScheduledReplayBufferSupplier.get()

Method parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type FlowableReplay.ReplayBuffer

Modifier and Type	Method	Description
(package private) static <T> ConnectableFlowable<T>	FlowableReplay.create(Flowable<T> source, Supplier<? extends FlowableReplay.ReplayBuffer<T>> bufferFactory)	Creates a OperatorReplay instance to replay values of the given source Flowable.

Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type FlowableReplay.ReplayBuffer

Modifier	Constructor	Description
(package private)	ReplaySubscriber(FlowableReplay.ReplayBuffer<T> buffer, AtomicReference<FlowableReplay.ReplaySubscriber<T>> current)

Constructor parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type FlowableReplay.ReplayBuffer

Modifier	Constructor	Description
private	FlowableReplay(org.reactivestreams.Publisher<T> onSubscribe, Flowable<T> source, AtomicReference<FlowableReplay.ReplaySubscriber<T>> current, Supplier<? extends FlowableReplay.ReplayBuffer<T>> bufferFactory)
(package private)	ReplayPublisher(AtomicReference<FlowableReplay.ReplaySubscriber<T>> curr, Supplier<? extends FlowableReplay.ReplayBuffer<T>> bufferFactory)