Uses of Interface
rx.internal.operators.OperatorReplay.ReplayBuffer
-
Packages that use OperatorReplay.ReplayBuffer Package Description rx.internal.operators 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.ReplayBuffer Modifier and Type Class Description (package private) static class
OperatorReplay.BoundedReplayBuffer<T>
Base class for bounded buffering with options to specify an enter and leave transforms and custom truncation behavior.(package private) static class
OperatorReplay.SizeAndTimeBoundReplayBuffer<T>
Size and time bound replay buffer.(package private) static class
OperatorReplay.SizeBoundReplayBuffer<T>
A bounded replay buffer implementation with size limit only.(package private) static class
OperatorReplay.UnboundedReplayBuffer<T>
Holds an unbounded list of events.Fields in rx.internal.operators declared as OperatorReplay.ReplayBuffer Modifier and Type Field Description (package private) OperatorReplay.ReplayBuffer<T>
OperatorReplay.ReplaySubscriber. buffer
Holds notifications from upstream.Fields in rx.internal.operators with type parameters of type OperatorReplay.ReplayBuffer Modifier and Type Field Description (package private) 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.ReplayBuffer Modifier and Type Method Description (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.ReplayBuffer Constructor Description ReplaySubscriber(OperatorReplay.ReplayBuffer<T> buffer)
Constructor parameters in rx.internal.operators with type arguments of type OperatorReplay.ReplayBuffer Constructor Description OperatorReplay(Observable.OnSubscribe<T> onSubscribe, Observable<? extends T> source, java.util.concurrent.atomic.AtomicReference<OperatorReplay.ReplaySubscriber<T>> current, Func0<? extends OperatorReplay.ReplayBuffer<T>> bufferFactory)
-