| Package | Description |
|---|---|
| rx |
Rx Observables
|
| rx.functions | |
| rx.internal.operators |
Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.
|
| rx.observables |
| Modifier and Type | Interface and Description |
|---|---|
static interface |
Observable
Invoked when Observable.subscribe is called.
|
static interface |
Single
Invoked when Single.execute is called.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
Action0
A zero-argument action.
|
interface |
Action1<T>
A one-argument action.
|
interface |
Action2<T1
A two-argument action.
|
interface |
Action3<T1
A three-argument action.
|
interface |
Action4<T1
A four-argument action.
|
interface |
Action5<T1
A five-argument action.
|
interface |
Action6<T1
A six-argument action.
|
interface |
Action7<T1
A seven-argument action.
|
interface |
Action8<T1
An eight-argument action.
|
interface |
Action9<T1
A nine-argument action.
|
interface |
ActionN
A vector-argument action.
|
| Modifier and Type | Class and Description |
|---|---|
class |
OnSubscribeAmb<T>
Given multiple
Observables, propagates the one that first emits an item.
|
class |
OnSubscribeAutoConnect<T>
Wraps a ConnectableObservable and calls its connect() method once the specified number of Subscribers have subscribed.
|
class |
OnSubscribeCombineLatest<T
Returns an Observable that combines the emissions of multiple source observables.
|
class |
OnSubscribeDefer<T>
Do not create the Observable until an Observer subscribes; create a fresh Observable on each subscription.
|
class |
OnSubscribeDelaySubscription<T>
Delays the subscription to the source by the given amount, running on the given scheduler.
|
class |
OnSubscribeDelaySubscriptionWithSelector<T
Delays the subscription until the Observable emits an event.
|
class |
OnSubscribeFromCallable<T>
Do not invoke the function until an Observer subscribes; Invokes function on each subscription.
|
class |
OnSubscribeFromIterable<T>
Converts an
Iterable sequence into an
Observable.
|
class |
OnSubscribeGroupJoin<T1
Corrrelates two sequences when they overlap and groups the results.
|
class |
OnSubscribeJoin<TLeft
Correlates the elements of two sequences based on overlapping durations.
|
class |
OnSubscribeRange
Emit ints from start to end inclusive.
|
class |
OnSubscribeRedo<T>
|
class |
OnSubscribeRefCount<T>
Returns an observable sequence that stays connected to the source as long as there is at least one subscription to the observable sequence.
|
class |
OnSubscribeSingle<T>
Allows conversion of an Observable to a Single ensuring that exactly one item is emitted - no more and no less.
|
class |
OnSubscribeTimerOnce
Timer that emits a single 0L and completes after the specified time.
|
class |
OnSubscribeTimerPeriodically
Emit 0L after the initial period and ever increasing number after each period.
|
class |
OnSubscribeUsing<T
Constructs an observable sequence that depends on a resource object.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AsyncOnSubscribe<S
A utility class to create
OnSubscribe<T> functions that respond correctly to back pressure requests from subscribers.
|
class |
SyncOnSubscribe<S
A utility class to create
OnSubscribe<T> functions that respond correctly to back pressure requests from subscribers.
|