Uses of Class
rx.observables.ConnectableObservable

Packages that use ConnectableObservable

Package	Description
rx	Base reactive classes: Observable, Single and Completable; base reactive consumers; other common base interfaces.
rx.internal.operators	Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.
rx.internal.util

Uses of ConnectableObservable in rx

Methods in rx that return ConnectableObservable

Modifier and Type	Method	Description
final ConnectableObservable<T>	Observable.publish()	Returns a ConnectableObservable, which is a variety of Observable that waits until its connect method is called before it begins emitting items to those Observers that have subscribed to it.
final ConnectableObservable<T>	Observable.replay()	Returns a ConnectableObservable that shares a single subscription to the underlying Observable that will replay all of its items and notifications to any future Observer.
final ConnectableObservable<T>	Observable.replay(int bufferSize)	Returns a ConnectableObservable that shares a single subscription to the source Observable that replays at most bufferSize items emitted by that Observable.
final ConnectableObservable<T>	Observable.replay(int bufferSize, long time, TimeUnit unit)	Returns a ConnectableObservable that shares a single subscription to the source Observable and replays at most bufferSize items that were emitted during a specified time window.
final ConnectableObservable<T>	Observable.replay(int bufferSize, long time, TimeUnit unit, Scheduler scheduler)	Returns a ConnectableObservable that shares a single subscription to the source Observable and that replays a maximum of bufferSize items that are emitted within a specified time window.
final ConnectableObservable<T>	Observable.replay(int bufferSize, Scheduler scheduler)	Returns a ConnectableObservable that shares a single subscription to the source Observable and replays at most bufferSize items emitted by that Observable.
final ConnectableObservable<T>	Observable.replay(long time, TimeUnit unit)	Returns a ConnectableObservable that shares a single subscription to the source Observable and replays all items emitted by that Observable within a specified time window.
final ConnectableObservable<T>	Observable.replay(long time, TimeUnit unit, Scheduler scheduler)	Returns a ConnectableObservable that shares a single subscription to the source Observable and replays all items emitted by that Observable within a specified time window.
final ConnectableObservable<T>	Observable.replay(Scheduler scheduler)	Returns a ConnectableObservable that shares a single subscription to the source Observable that will replay all of its items and notifications to any future Observer on the given Scheduler.

Uses of ConnectableObservable in rx.internal.operators

Subclasses of ConnectableObservable in rx.internal.operators

Modifier and Type	Class	Description
final class	OperatorMulticast<T,R>	Shares a single subscription to a source through a Subject.
final class	OperatorPublish<T>	A connectable observable which shares an underlying source and dispatches source values to subscribers in a backpressure-aware manner.
final class	OperatorReplay<T>

Fields in rx.internal.operators declared as ConnectableObservable

Modifier and Type	Field	Description
(package private) final ConnectableObservable<? extends T>	OnSubscribeAutoConnect.source
private final ConnectableObservable<? extends T>	OnSubscribeRefCount.source

Methods in rx.internal.operators that return ConnectableObservable

Modifier and Type	Method	Description
static <T> ConnectableObservable<T>	OperatorPublish.create(Observable<? extends T> source)	Creates a OperatorPublish instance to publish values of the given source observable.
static <T> ConnectableObservable<T>	OperatorReplay.create(Observable<? extends T> source)	Creates a replaying ConnectableObservable with an unbounded buffer.
static <T> ConnectableObservable<T>	OperatorReplay.create(Observable<? extends T> source, int bufferSize)	Creates a replaying ConnectableObservable with a size bound buffer.
static <T> ConnectableObservable<T>	OperatorReplay.create(Observable<? extends T> source, long maxAge, TimeUnit unit, Scheduler scheduler)	Creates a replaying ConnectableObservable with a time bound buffer.
static <T> ConnectableObservable<T>	OperatorReplay.create(Observable<? extends T> source, long maxAge, TimeUnit unit, Scheduler scheduler, int bufferSize)	Creates a replaying ConnectableObservable with a size and time bound buffer.
(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.
static <T> ConnectableObservable<T>	OperatorReplay.observeOn(ConnectableObservable<T> co, Scheduler scheduler)	Child Subscribers will observe the events of the ConnectableObservable on the specified scheduler.

Methods in rx.internal.operators with parameters of type ConnectableObservable

Modifier and Type	Method	Description
static <T> ConnectableObservable<T>	OperatorReplay.observeOn(ConnectableObservable<T> co, Scheduler scheduler)	Child Subscribers will observe the events of the ConnectableObservable on the specified scheduler.

Method parameters in rx.internal.operators with type arguments of type ConnectableObservable

Modifier and Type	Method	Description
static <T, U, R> Observable<R>	OperatorReplay.multicastSelector(Func0<? extends ConnectableObservable<U>> connectableFactory, Func1<? super Observable<U>,? extends Observable<R>> selector)	Given a connectable observable factory, it multicasts over the generated ConnectableObservable via a selector function.

Constructors in rx.internal.operators with parameters of type ConnectableObservable

Modifier	Constructor	Description
	OnSubscribeAutoConnect(ConnectableObservable<? extends T> source, int numberOfSubscribers, Action1<? super Subscription> connection)
	OnSubscribeRefCount(ConnectableObservable<? extends T> source)	Constructor.

Uses of ConnectableObservable in rx.internal.util

Methods in rx.internal.util that return ConnectableObservable

Modifier and Type	Method	Description
ConnectableObservable<T>	InternalObservableUtils.ReplaySupplierBuffer.call()
ConnectableObservable<T>	InternalObservableUtils.ReplaySupplierBufferTime.call()
ConnectableObservable<T>	InternalObservableUtils.ReplaySupplierNoParams.call()
ConnectableObservable<T>	InternalObservableUtils.ReplaySupplierTime.call()

Methods in rx.internal.util that return types with arguments of type ConnectableObservable

Modifier and Type	Method	Description
static <T> Func0<ConnectableObservable<T>>	InternalObservableUtils.createReplaySupplier(Observable<T> source)	Returns a Func0 that supplies the ConnectableObservable returned by calling replay() on the source.
static <T> Func0<ConnectableObservable<T>>	InternalObservableUtils.createReplaySupplier(Observable<T> source, int bufferSize)	Returns a Func0 that supplies the ConnectableObservable returned by calling a parameterized replay() on the source.
static <T> Func0<ConnectableObservable<T>>	InternalObservableUtils.createReplaySupplier(Observable<T> source, int bufferSize, long time, TimeUnit unit, Scheduler scheduler)	Returns a Func0 that supplies the ConnectableObservable returned by calling a parameterized replay() on the source.
static <T> Func0<ConnectableObservable<T>>	InternalObservableUtils.createReplaySupplier(Observable<T> source, long time, TimeUnit unit, Scheduler scheduler)	Returns a Func0 that supplies the ConnectableObservable returned by calling a parameterized replay() on the source.