Top Inners Fields Constructors Methods

io.reactivex.internal.operators.observable

public final Class ObservableReplay<T>

Class Inheritance

extends ConnectableObservable<T>
implements HasUpstreamObservableSource<T>, ResettableConnectable

java.lang.Object
io.reactivex.Observable
io.reactivex.observables.ConnectableObservable
io.reactivex.internal.operators.observable.ObservableReplay

All Implemented Interfaces

io.reactivex.internal.disposables.ResettableConnectable, io.reactivex.internal.fuseable.HasUpstreamObservableSource

Imports

java.util.*, java.util.concurrent.*, java.util.concurrent.atomic.*, io.reactivex.*, .Observable, .Observer, io.reactivex.disposables.Disposable, io.reactivex.exceptions.Exceptions, io.reactivex.functions.*, io.reactivex.internal.disposables.*, io.reactivex.internal.functions.ObjectHelper, io.reactivex.internal.fuseable.HasUpstreamObservableSource, io.reactivex.internal.util.*, io.reactivex.observables.ConnectableObservable, io.reactivex.plugins.RxJavaPlugins, io.reactivex.schedulers.Timed

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv abstract static class	ObservableReplay.BoundedReplayBuffer< the value type T> Base class for bounded buffering with options to specify an enter and leave transforms and custom truncation behavior.
pack-priv static interface	ObservableReplay.BufferSupplier<T>
pack-priv static class	ObservableReplay.DisposeConsumer<R>
pack-priv static class	ObservableReplay.InnerDisposable< the value type T> A Disposable that manages the disposed state of a child Observer in thread-safe manner.
pack-priv static class	ObservableReplay.MulticastReplay<R, U>
pack-priv static class	ObservableReplay.Node Represents a node in a bounded replay buffer's linked list.
pack-priv static class	ObservableReplay.Replay<T>
pack-priv static interface	ObservableReplay.ReplayBuffer< the value type T> The interface for interacting with various buffering logic.
pack-priv static class	ObservableReplay.ReplayBufferSupplier<T>
pack-priv static class	ObservableReplay.ReplayObserver<T>
pack-priv static class	ObservableReplay.ReplaySource<T>
pack-priv static class	ObservableReplay.ScheduledReplaySupplier<T>
pack-priv static class	ObservableReplay.SizeAndTimeBoundReplayBuffer< the buffered value type T> Size and time bound replay buffer.
pack-priv static class	ObservableReplay.SizeBoundReplayBuffer< the value type T> A bounded replay buffer implementation with size limit only.
pack-priv static class	ObservableReplay.UnBoundedFactory
pack-priv static class	ObservableReplay.UnboundedReplayBuffer< the value type T> Holds an unbounded list of events.

Field Summary

Modifier and Type	Field and Description
pack-priv final ObservableReplay.BufferSupplier<T>	bufferFactory A factory that creates the appropriate buffer for the ReplayObserver.
pack-priv final AtomicReference<ObservableReplay.ReplayObserver<T>>	current Holds the current subscriber that is, will be or just was subscribed to the source observable.
pack-priv static final ObservableReplay.BufferSupplier<T>	DEFAULT_UNBOUNDED_FACTORY
pack-priv final ObservableSource<T>	onSubscribe
pack-priv final ObservableSource<T>	source The source observable.

Constructor Summary

Access	Constructor and Description
private	ObservableReplay(ObservableSource<T> onSubscribe, ObservableSource<T> source, final AtomicReference<ObservableReplay.ReplayObserver<T>> current, final ObservableReplay.BufferSupplier<T> bufferFactory)

Method Summary

Modifier and Type	Method and Description
public void	connect(Consumer<? super Disposable> the action that receives the connection subscription before the subscription to source happens allowing the caller to synchronously disconnect a synchronous source connection) Implements abstract io.reactivex.observables.ConnectableObservable.connect. Instructs the `ConnectableObservable` to begin emitting the items from its underlying `Observable` to its `Observer`s.
public static < the value type T> ConnectableObservable<T>	Returns: the new ConnectableObservable instance create(ObservableSource<T> the source ObservableSource to use source, final int the maximum number of elements to hold bufferSize) Creates a replaying ConnectableObservable with a size bound buffer.
public static < the value type T> ConnectableObservable<T>	Returns: the new ConnectableObservable instance create(ObservableSource<T> the source ObservableSource to use source, long the maximum age of entries maxAge, TimeUnit the unit of measure of the age amount unit, Scheduler the target scheduler providing the current time scheduler) Creates a replaying ConnectableObservable with a time bound buffer.
public static < the value type T> ConnectableObservable<T>	Returns: the new ConnectableObservable instance create(ObservableSource<T> the source ObservableSource to use source, final long the maximum age of entries maxAge, final TimeUnit the unit of measure of the age amount unit, final Scheduler the target scheduler providing the current time scheduler, final int the maximum number of elements to hold bufferSize) Creates a replaying ConnectableObservable with a size and time bound buffer.
pack-priv static <T> ConnectableObservable<T>	Returns: the connectable observable create(ObservableSource<T> the source observable source, final ObservableReplay.BufferSupplier<T> the factory to instantiate the appropriate buffer when the observable becomes active bufferFactory) Creates a OperatorReplay instance to replay values of the given source observable.
public static < the value type T> ConnectableObservable<T>	Returns: the new ConnectableObservable instance createFrom(ObservableSource<? extends T> the source observable source) Creates a replaying ConnectableObservable with an unbounded buffer.
public static < the value type of the ConnectableObservable U, the result value type R> Observable<R>	Returns: the new Observable instance multicastSelector(final Callable<? extends ConnectableObservable<U>> the factory that returns a ConnectableObservable for each individual subscriber connectableFactory, final Function<? super Observable<U>, ? extends ObservableSource<R>> the function that receives an Observable and should return another Observable that will be subscribed to selector) Given a connectable observable factory, it multicasts over the generated ConnectableObservable via a selector function.
public static < the value type T> ConnectableObservable<T>	Returns: the new ConnectableObservable instance observeOn(final ConnectableObservable<T> the connectable observable instance co, final Scheduler the target scheduler scheduler) Child Observers will observe the events of the ConnectableObservable on the specified scheduler.
public void	resetIf(Disposable the disposable received from a previous `connect()` call. connectionObject) Implements io.reactivex.internal.disposables.ResettableConnectable.resetIf. Reset the connectable source only if the given `Disposable` `connection` instance is still representing a connection established by a previous `connect()` connection.
public ObservableSource<T>	source() Implements io.reactivex.internal.fuseable.HasUpstreamObservableSource.source. Returns the upstream source of this Observable.
protected void	subscribeActual(Observer<? super T> the incoming Observer, never null observer) Implements abstract io.reactivex.Observable.subscribeActual. Operator implementations (both source and intermediate) should implement this method that performs the necessary business logic and handles the incoming `Observer`s.

Inherited from io.reactivex.observables.ConnectableObservable:: autoConnect autoConnect autoConnect connect refCount refCount refCount refCount refCount refCount