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)