Package rx.internal.operators
Class OperatorGroupBy<T,K,V>
java.lang.Object
rx.internal.operators.OperatorGroupBy<T,K,V>
- Type Parameters:
T
- the source and group value typeK
- the key typeV
- the value type of the groups
- All Implemented Interfaces:
Func1<Subscriber<? super GroupedObservable<K,
,V>>, Subscriber<? super T>> Function
,Observable.Operator<GroupedObservable<K,
V>, T>
public final class OperatorGroupBy<T,K,V>
extends Object
implements Observable.Operator<GroupedObservable<K,V>,T>
Groups the items emitted by an Observable according to a specified criterion, and emits these
grouped items as Observables, one Observable per group.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic final class
static final class
(package private) static final class
(package private) static final class
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final int
(package private) final boolean
-
Constructor Summary
ConstructorsConstructorDescriptionOperatorGroupBy
(Func1<? super T, ? extends K> keySelector) OperatorGroupBy
(Func1<? super T, ? extends K> keySelector, Func1<? super T, ? extends V> valueSelector) OperatorGroupBy
(Func1<? super T, ? extends K> keySelector, Func1<? super T, ? extends V> valueSelector, int bufferSize, boolean delayError, Func1<Action1<K>, Map<K, Object>> mapFactory) OperatorGroupBy
(Func1<? super T, ? extends K> keySelector, Func1<? super T, ? extends V> valueSelector, Func1<Action1<K>, Map<K, Object>> mapFactory) -
Method Summary
Modifier and TypeMethodDescriptionSubscriber
<? super T> call
(Subscriber<? super GroupedObservable<K, V>> child)