| 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.
|
| Modifier and Type | Interface and Description |
|---|---|
static interface |
Observable
Invoked when Obserable.subscribe is called.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
Action0
A zero-argument action.
|
interface |
Action1<T1>
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 |
OnSubscribeCache<T>
This method has similar behavior to
Observable except that this auto-subscribes to the source Observable rather than returning a connectable Observable.
|
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 |
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 |
OnSubscribeMulticastSelector<TInput
Returns an observable sequence that contains the elements of a sequence produced by multicasting the source sequence within a selector function.
|
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 |
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.
|