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 |
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 . |
Modifier and Type | Class and 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> |
Modifier and Type | Method and Description |
---|---|
static <T> ConnectableObservable<T> |
OperatorReplay.create(Observable<? extends T> source)
Creates a replaying ConnectableObservable with an unbounded buffer.
|
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,
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.
|
static <T> ConnectableObservable<T> |
OperatorReplay.observeOn(ConnectableObservable<T> co,
Scheduler scheduler)
Child Subscribers will observe the events of the ConnectableObservable on the
specified scheduler.
|
Modifier and Type | Method and 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.
|
Modifier and Type | Method and 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.
|
Constructor and Description |
---|
OnSubscribeAutoConnect(ConnectableObservable<? extends T> source,
int numberOfSubscribers,
Action1<? super Subscription> connection) |
OnSubscribeRefCount(ConnectableObservable<? extends T> source)
Constructor.
|
Modifier and Type | Method and 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.
|
Copyright © 2017. All rights reserved.