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 class
FlowableReplay.SizeAndTimeBoundReplayBuffer<T>
Size and time bound replay buffer.(package private) static class
FlowableReplay.SizeBoundReplayBuffer<T>
A bounded replay buffer implementation with size limit only.(package private) static class
FlowableReplay.UnboundedReplayBuffer<T>
Holds an unbounded list of events.Fields in io.reactivex.rxjava3.internal.operators.flowable declared as FlowableReplay.ReplayBuffer Modifier and Type Field Description (package private) 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) Supplier<? extends FlowableReplay.ReplayBuffer<T>>
FlowableReplay. bufferFactory
A factory that creates the appropriate buffer for the ReplaySubscriber.private 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 sourceFlowable
.Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type FlowableReplay.ReplayBuffer Constructor Description ReplaySubscriber(FlowableReplay.ReplayBuffer<T> buffer, java.util.concurrent.atomic.AtomicReference<FlowableReplay.ReplaySubscriber<T>> current)
Constructor parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type FlowableReplay.ReplayBuffer Constructor Description FlowableReplay(org.reactivestreams.Publisher<T> onSubscribe, Flowable<T> source, java.util.concurrent.atomic.AtomicReference<FlowableReplay.ReplaySubscriber<T>> current, Supplier<? extends FlowableReplay.ReplayBuffer<T>> bufferFactory)
ReplayPublisher(java.util.concurrent.atomic.AtomicReference<FlowableReplay.ReplaySubscriber<T>> curr, Supplier<? extends FlowableReplay.ReplayBuffer<T>> bufferFactory)
-