Uses of Interface
rx.internal.operators.OperatorReplay.ReplayBuffer
Packages that use OperatorReplay.ReplayBuffer
Package
Description
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
-
Uses of OperatorReplay.ReplayBuffer in rx.internal.operators
Classes in rx.internal.operators that implement OperatorReplay.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 rx.internal.operators declared as OperatorReplay.ReplayBufferModifier and TypeFieldDescription(package private) final OperatorReplay.ReplayBuffer
<T> OperatorReplay.ReplaySubscriber.buffer
Holds notifications from upstream.Fields in rx.internal.operators with type parameters of type OperatorReplay.ReplayBufferModifier and TypeFieldDescription(package private) final Func0
<? extends OperatorReplay.ReplayBuffer<T>> OperatorReplay.bufferFactory
A factory that creates the appropriate buffer for the ReplaySubscriber.Method parameters in rx.internal.operators with type arguments of type OperatorReplay.ReplayBufferModifier and TypeMethodDescription(package private) static <T> ConnectableObservable
<T> OperatorReplay.create
(Observable<? extends T> source, Func0<? extends OperatorReplay.ReplayBuffer<T>> bufferFactory) Creates a OperatorReplay instance to replay values of the given source observable.Constructors in rx.internal.operators with parameters of type OperatorReplay.ReplayBufferConstructor parameters in rx.internal.operators with type arguments of type OperatorReplay.ReplayBufferModifierConstructorDescriptionprivate
OperatorReplay
(Observable.OnSubscribe<T> onSubscribe, Observable<? extends T> source, AtomicReference<OperatorReplay.ReplaySubscriber<T>> current, Func0<? extends OperatorReplay.ReplayBuffer<T>> bufferFactory)