| 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 | Method and Description |
|---|---|
<TClosing> Observable |
Observable.buffer(Func0
Returns an Observable that emits buffers of items it collects from the source Observable.
|
<R> Observable |
Observable.collect(Func0
Collects items emitted by the source Observable into a single mutable data structure and returns an Observable that emits this structure.
|
static <T> Observable |
Observable.defer(Func0
Returns an Observable that calls an Observable factory to create an Observable for each new Observer that subscribes.
|
<U |
Observable.delay(Func0
Returns an Observable that delays the subscription to and emissions from the souce Observable via another Observable on a per-item basis.
|
<U> Observable |
Observable.delaySubscription(Func0
Returns an Observable that delays the subscription to the source Observable until a second Observable emits an item.
|
<R> Observable |
Observable.flatMap(Func1
Returns an Observable that applies a function to each item emitted or notification raised by the source Observable and then flattens the Observables returned from these functions and emits the resulting items.
|
<U |
Observable.timeout(Func0
Returns an Observable that mirrors the source Observable, but notifies observers of a
TimeoutException if either the first item emitted by the source Observable or any subsequent item doesn't arrive within time windows defined by other Observables.
|
<U |
Observable.timeout(Func0
Returns an Observable that mirrors the source Observable, but switches to a fallback Observable if either the first item emitted by the source Observable or any subsequent item doesn't arrive within time windows defined by other Observables.
|
<K |
Observable.toMap(Func1
Returns an Observable that emits a single Map, returned by a specified
mapFactory function, that contains keys and values extracted from the items emitted by the source Observable.
|
<K |
Observable.toMultimap(Func1
Returns an Observable that emits a single Map, returned by a specified
mapFactory function, that contains an ArrayList of values, extracted by a specified
valueSelector function from items emitted by the source Observable and keyed by the
keySelector function.
|
<K |
Observable.toMultimap(Func1
Returns an Observable that emits a single Map, returned by a specified
mapFactory function, that contains a custom collection of values, extracted by a specified
valueSelector function from items emitted by the source Observable, and keyed by the
keySelector function.
|
static <T |
Observable.using(Func0
Constructs an Observable that creates a dependent resource object.
|
<TClosing> Observable |
Observable.window(Func0
Returns an Observable that emits windows of items it collects from the source Observable.
|
| Modifier and Type | Method and Description |
|---|---|
static Func0 |
Actions.toFunc(Action0
Converts an
Action0 to a function that calls the action and returns
null.
|
static <R> Func0 |
Actions.toFunc(Action0
Converts an
Action0 to a function that calls the action and returns a specified value.
|
| Modifier and Type | Method and Description |
|---|---|
static <R> FuncN |
Functions.fromFunc(Func0
|
| Modifier and Type | Class and Description |
|---|---|
static class |
OperatorToMap
The default map factory.
|
static class |
OperatorToMultimap
The default multimap factory returning a HashMap.
|
| Constructor and Description | |
|---|---|
OnSubscribeDefer(Func0
|
|
OnSubscribeDelaySubscriptionWithSelector(Observable
|
|
OnSubscribeMulticastSelector(Observable
|
|
OnSubscribeUsing(Func0
|
|
OperatorBufferWithSingleObservable(Func0
|
|
OperatorMapNotification(Func1
|
|
OperatorMulticast(Observable
|
|
OperatorScan(Func0
|
|
OperatorTimeoutWithSelector(Func0
|
|
OperatorToMap(Func1
ToMap with key selector, value selector and custom Map factory.
|
|
OperatorToMultimap(Func1
ToMultimap with key selector, custom value selector, custom Map factory and default ArrayList collection factory.
|
|
OperatorToMultimap(Func1
ToMultimap with key selector, custom value selector, custom Map factory and custom collection factory.
|
|
OperatorWindowWithObservable(Func0
|