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 type

K - the key type

V - 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 Classes

Modifier and Type	Class	Description
static final class	OperatorGroupBy.GroupByProducer
static final class	OperatorGroupBy.GroupBySubscriber<T,K,V>
(package private) static final class	OperatorGroupBy.GroupedUnicast<K,T>
(package private) static final class	OperatorGroupBy.State<T,K>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final int	bufferSize
(package private) final boolean	delayError
(package private) final Func1<? super T,? extends K>	keySelector
(package private) final Func1<Action1<K>,Map<K,Object>>	mapFactory
(package private) final 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>,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 Type	Method	Description
Subscriber<? super T>	call(Subscriber<? super GroupedObservable<K,V>> child)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

keySelector

final Func1<? super T,? extends K> keySelector

valueSelector

final Func1<? super T,? extends V> valueSelector

bufferSize

final int bufferSize

delayError

final boolean delayError

mapFactory

final Func1<Action1<K>,Map<K,Object>> mapFactory

Constructor Details

OperatorGroupBy

public OperatorGroupBy(Func1<? super T,? extends K> keySelector)

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>,Map<K,Object>> mapFactory)

OperatorGroupBy

public OperatorGroupBy(Func1<? super T,? extends K> keySelector,
 Func1<? super T,? extends V> valueSelector,
 int bufferSize,
 boolean delayError,
 Func1<Action1<K>,Map<K,Object>> mapFactory)

Method Details

call

public Subscriber<? super T> call(Subscriber<? super GroupedObservable<K,V>> child)

Specified by:

call in interface Func1<T,K>