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)
Deprecated.
since 1.3.7, use
Observable.groupBy(Func1, Func1, int, boolean, Func1)
instead which uses much less memory. Please take note of the
usage difference involving the evicting action which now expects
the value from the map instead of the key. |
<K,R> Observable<GroupedObservable<K,R>> |
Observable.groupBy(Func1<? super T,? extends K> keySelector,
Func1<? super T,? extends R> elementSelector,
int bufferSize,
boolean delayError,
Func1<Action1<Object>,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> |
OperatorGroupByEvicting.call(Subscriber<? super GroupedObservable<K,V>> child) |
Subscriber<? super T> |
OperatorGroupBy.call(Subscriber<? super GroupedObservable<K,V>> child)
Deprecated.
|
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) |
GroupBySubscriber(Subscriber<? super GroupedObservable<K,V>> actual,
Func1<? super T,? extends K> keySelector,
Func1<? super T,? extends V> valueSelector,
int bufferSize,
boolean delayError,
Map<K,rx.internal.operators.OperatorGroupByEvicting.GroupedUnicast<K,V>> groups,
Queue<rx.internal.operators.OperatorGroupByEvicting.GroupedUnicast<K,V>> evictedGroups) |
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.