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 classBase class for bounded buffering with options to specify an enter and leave transforms and custom truncation behavior.(package private) static final classSize and time bound replay buffer.(package private) static final classA bounded replay buffer implementation with size limit only.(package private) static final classHolds an unbounded list of events.Fields in rx.internal.operators declared as OperatorReplay.ReplayBufferModifier and TypeFieldDescription(package private) final OperatorReplay.ReplayBuffer<T> OperatorReplay.ReplaySubscriber.bufferHolds 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.bufferFactoryA 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.ReplayBufferModifierConstructorDescriptionprivateOperatorReplay(Observable.OnSubscribe<T> onSubscribe, Observable<? extends T> source, AtomicReference<OperatorReplay.ReplaySubscriber<T>> current, Func0<? extends OperatorReplay.ReplayBuffer<T>> bufferFactory)