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 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.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
.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.ConnectableObservable<T>
Observable. replay(int bufferSize, long time, java.util.concurrent.TimeUnit unit)
Returns aConnectableObservable
that shares a single subscription to the source Observable and replays at mostbufferSize
items that were emitted during a specified time window.ConnectableObservable<T>
Observable. replay(int bufferSize, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
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.ConnectableObservable<T>
Observable. replay(int bufferSize, Scheduler scheduler)
Returns aConnectableObservable
that shares a single subscription to the source Observable and replays at mostbufferSize
items emitted by that Observable.ConnectableObservable<T>
Observable. replay(long time, java.util.concurrent.TimeUnit unit)
Returns aConnectableObservable
that shares a single subscription to the source Observable and replays all items emitted by that Observable within a specified time window.ConnectableObservable<T>
Observable. replay(long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
Returns aConnectableObservable
that shares a single subscription to the source Observable and replays all items emitted by that Observable within a specified time window.ConnectableObservable<T>
Observable. replay(Scheduler scheduler)
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.operators Modifier and Type Class Description class
OperatorMulticast<T,R>
Shares a single subscription to a source through a Subject.class
OperatorPublish<T>
A connectable observable which shares an underlying source and dispatches source values to subscribers in a backpressure-aware manner.class
OperatorReplay<T>
Fields in rx.internal.operators declared as ConnectableObservable Modifier and Type Field Description (package private) ConnectableObservable<? extends T>
OnSubscribeAutoConnect. source
private 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, java.util.concurrent.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, java.util.concurrent.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 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, java.util.concurrent.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, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
Returns a Func0 that supplies the ConnectableObservable returned by calling a parameterized replay() on the source.
-