Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
io.reactivex.internal.operators.observable |
Modifier and Type | Method and Description |
---|---|
<K> Observable<GroupedObservable<K,T>> |
Observable.groupBy(Function<? super T,? extends K> keySelector)
Groups the items emitted by an
ObservableSource according to a specified criterion, and emits these
grouped items as GroupedObservable s. |
<K> Observable<GroupedObservable<K,T>> |
Observable.groupBy(Function<? super T,? extends K> keySelector,
boolean delayError)
Groups the items emitted by an
ObservableSource according to a specified criterion, and emits these
grouped items as GroupedObservable s. |
<K,V> Observable<GroupedObservable<K,V>> |
Observable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector)
Groups the items emitted by an
ObservableSource according to a specified criterion, and emits these
grouped items as GroupedObservable s. |
<K,V> Observable<GroupedObservable<K,V>> |
Observable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
boolean delayError)
Groups the items emitted by an
ObservableSource according to a specified criterion, and emits these
grouped items as GroupedObservable s. |
<K,V> Observable<GroupedObservable<K,V>> |
Observable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
boolean delayError,
int bufferSize)
Groups the items emitted by an
ObservableSource according to a specified criterion, and emits these
grouped items as GroupedObservable s. |
Modifier and Type | Method and Description |
---|---|
void |
ObservableGroupBy.subscribeActual(Observer<? super GroupedObservable<K,V>> t) |
Constructor and Description |
---|
GroupByObserver(Observer<? super GroupedObservable<K,V>> actual,
Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
int bufferSize,
boolean delayError) |
Copyright © 2019. All rights reserved.