| Package | Description |
|---|---|
| rx |
Rx Observables
|
| 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 | Method and Description |
|---|---|
<K> Observable |
Observable.groupBy(Func1
Groups the items emitted by an
Observable according to a specified criterion, and emits these grouped items as
GroupedObservables, one
GroupedObservable per group.
|
<K |
Observable.groupBy(Func1
Groups the items emitted by an
Observable according to a specified criterion, and emits these grouped items as
GroupedObservables, one
GroupedObservable per group.
|
| Modifier and Type | Method and Description |
|---|---|
Subscriber |
OperatorGroupBy.call(Subscriber
|
| Modifier and Type | Method and Description |
|---|---|
static <K |
GroupedObservable.create(K key, Observable
Returns an Observable that will execute the specified function when a
Subscriber subscribes to it.
|
static <K |
GroupedObservable.from(K key, Observable
Converts an
Observable into a
GroupedObservable with a particular key.
|