Package rx.internal.operators
Class OperatorGroupBy<T,K,V>
- java.lang.Object
-
- rx.internal.operators.OperatorGroupBy<T,K,V>
-
- Type Parameters:
K
- the key typeT
- the source and group value 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 java.lang.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 Classes Modifier and Type Class Description static class
OperatorGroupBy.GroupByProducer
static class
OperatorGroupBy.GroupBySubscriber<T,K,V>
(package private) static class
OperatorGroupBy.GroupedUnicast<K,T>
(package private) static class
OperatorGroupBy.State<T,K>
-
Field Summary
Fields Modifier and Type Field Description (package private) int
bufferSize
(package private) boolean
delayError
(package private) Func1<? super T,? extends K>
keySelector
(package private) Func1<Action1<K>,java.util.Map<K,java.lang.Object>>
mapFactory
(package private) Func1<? super T,? extends V>
valueSelector
-
Constructor Summary
Constructors Constructor Description OperatorGroupBy(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>,java.util.Map<K,java.lang.Object>> mapFactory)
OperatorGroupBy(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func1<Action1<K>,java.util.Map<K,java.lang.Object>> mapFactory)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Subscriber<? super T>
call(Subscriber<? super GroupedObservable<K,V>> child)
-
-
-
Constructor Detail
-
OperatorGroupBy
public OperatorGroupBy(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector)
-
OperatorGroupBy
public OperatorGroupBy(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func1<Action1<K>,java.util.Map<K,java.lang.Object>> mapFactory)
-
-
Method Detail
-
call
public Subscriber<? super T> call(Subscriber<? super GroupedObservable<K,V>> child)
-
-