Uses of Interface
io.reactivex.rxjava3.internal.operators.flowable.FlowableReplay.ReplayBuffer
Packages that use FlowableReplay.ReplayBuffer
-
Uses of FlowableReplay.ReplayBuffer in io.reactivex.rxjava3.internal.operators.flowable
Classes in io.reactivex.rxjava3.internal.operators.flowable that implement FlowableReplay.ReplayBufferModifier and TypeClassDescription(package private) static class
Base class for bounded buffering with options to specify an enter and leave transforms and custom truncation behavior.(package private) static final class
Size and time bound replay buffer.(package private) static final class
A bounded replay buffer implementation with size limit only.(package private) static final class
Holds an unbounded list of events.Fields in io.reactivex.rxjava3.internal.operators.flowable declared as FlowableReplay.ReplayBufferModifier and TypeFieldDescription(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.ReplayBufferModifier and TypeFieldDescription(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.ReplayBufferModifier and TypeMethodDescriptionFlowableReplay.ReplayBufferSupplier.get()
FlowableReplay.ScheduledReplayBufferSupplier.get()
Method parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type FlowableReplay.ReplayBufferModifier and TypeMethodDescription(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 sourceFlowable
.Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type FlowableReplay.ReplayBufferModifierConstructorDescription(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.ReplayBufferModifierConstructorDescriptionprivate
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)