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.observables |
Classes extending the Observable base reactive class, synchronous and
asynchronous event generators.
|
Modifier and Type | Method and Description |
---|---|
<K> Observable<GroupedObservable<K,T>> |
Observable.groupBy(Func1<? super T,? extends K> keySelector)
Groups the items emitted by an
Observable according to a specified criterion, and emits these
grouped items as GroupedObservable s. |
<K,R> Observable<GroupedObservable<K,R>> |
Observable.groupBy(Func1<? super T,? extends K> keySelector,
Func1<? super T,? extends R> elementSelector)
Groups the items emitted by an
Observable according to a specified criterion, and emits these
grouped items as GroupedObservable s. |
<K,R> Observable<GroupedObservable<K,R>> |
Observable.groupBy(Func1<? super T,? extends K> keySelector,
Func1<? super T,? extends R> elementSelector,
Func1<Action1<K>,Map<K,Object>> evictingMapFactory)
Groups the items emitted by an
Observable according to a specified criterion, and emits these
grouped items as GroupedObservable s. |
Modifier and Type | Method and Description |
---|---|
Subscriber<? super T> |
OperatorGroupBy.call(Subscriber<? super GroupedObservable<K,V>> child) |
Constructor and Description |
---|
GroupBySubscriber(Subscriber<? super GroupedObservable<K,V>> actual,
Func1<? super T,? extends K> keySelector,
Func1<? super T,? extends V> valueSelector,
int bufferSize,
boolean delayError,
Func1<Action1<K>,Map<K,Object>> mapFactory) |
Modifier and Type | Method and Description |
---|---|
static <K,T> GroupedObservable<K,T> |
GroupedObservable.create(K key,
Observable.OnSubscribe<T> f)
Returns an Observable that will execute the specified function when a
Subscriber subscribes to
it. |
static <K,T> GroupedObservable<K,T> |
GroupedObservable.from(K key,
Observable<T> o)
Converts an
Observable into a GroupedObservable with a particular key. |
Copyright © 2018. All rights reserved.