Uses of Class
rx.observables.ConnectableObservable
Packages that use ConnectableObservable
Package
Description
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
-
Uses of ConnectableObservable in rx
Methods in rx that return ConnectableObservableModifier and TypeMethodDescriptionfinal ConnectableObservable
<T> Observable.publish()
Returns aConnectableObservable
, which is a variety of Observable that waits until itsconnect
method is called before it begins emitting items to thoseObserver
s that have subscribed to it.final ConnectableObservable
<T> Observable.replay()
Returns aConnectableObservable
that shares a single subscription to the underlying Observable that will replay all of its items and notifications to any futureObserver
.final ConnectableObservable
<T> Observable.replay
(int bufferSize) Returns aConnectableObservable
that shares a single subscription to the source Observable that replays at mostbufferSize
items emitted by that Observable.final ConnectableObservable
<T> Returns aConnectableObservable
that shares a single subscription to the source Observable and replays at mostbufferSize
items that were emitted during a specified time window.final ConnectableObservable
<T> Returns aConnectableObservable
that shares a single subscription to the source Observable and that replays a maximum ofbufferSize
items that are emitted within a specified time window.final ConnectableObservable
<T> Returns aConnectableObservable
that shares a single subscription to the source Observable and replays at mostbufferSize
items emitted by that Observable.final ConnectableObservable
<T> Returns aConnectableObservable
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> Returns aConnectableObservable
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> Returns aConnectableObservable
that shares a single subscription to the source Observable that will replay all of its items and notifications to any futureObserver
on the givenScheduler
. -
Uses of ConnectableObservable in rx.internal.operators
Subclasses of ConnectableObservable in rx.internal.operatorsModifier and TypeClassDescriptionfinal class
OperatorMulticast<T,
R> Shares a single subscription to a source through a Subject.final class
A connectable observable which shares an underlying source and dispatches source values to subscribers in a backpressure-aware manner.final class
Fields in rx.internal.operators declared as ConnectableObservableModifier and TypeFieldDescription(package private) final ConnectableObservable
<? extends T> OnSubscribeAutoConnect.source
private final ConnectableObservable
<? extends T> OnSubscribeRefCount.source
Methods in rx.internal.operators that return ConnectableObservableModifier and TypeMethodDescriptionstatic <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 ConnectableObservableModifier and TypeMethodDescriptionstatic <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 ConnectableObservableModifier and TypeMethodDescriptionstatic <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 ConnectableObservableModifierConstructorDescriptionOnSubscribeAutoConnect
(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 ConnectableObservableModifier and TypeMethodDescriptionInternalObservableUtils.ReplaySupplierBuffer.call()
InternalObservableUtils.ReplaySupplierBufferTime.call()
InternalObservableUtils.ReplaySupplierNoParams.call()
InternalObservableUtils.ReplaySupplierTime.call()
Methods in rx.internal.util that return types with arguments of type ConnectableObservableModifier and TypeMethodDescriptionstatic <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.