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.

  • 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