Package | Description |
---|---|
rx |
Rx Observables
|
Modifier and Type | Method and Description |
---|---|
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
Observer s that have subscribed to it. |
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 . |
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. |
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. |
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. |
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. |
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. |
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. |
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 . |
Copyright © 2015. All Rights Reserved.