com.github.davidmoten.rx.internal.operators

Class OperatorGroupBy.GroupBySubscriber<T,K,V>

java.lang.Object

rx.Subscriber<T>

com.github.davidmoten.rx.internal.operators.OperatorGroupBy.GroupBySubscriber<T,K,V>

All Implemented Interfaces:

rx.Observer<T>, rx.Subscription

Enclosing class:

OperatorGroupBy<T,K,V>

public static final class OperatorGroupBy.GroupBySubscriber<T,K,V>
extends rx.Subscriber<T>

Constructor Summary

Constructors

Constructor and Description
GroupBySubscriber(rx.Subscriber<? super rx.observables.GroupedObservable<K,V>> actual, rx.functions.Func1<? super T,? extends K> keySelector, rx.functions.Func1<? super T,? extends V> valueSelector, int bufferSize, boolean delayError, rx.functions.Func1<rx.functions.Action1<K>,Map<K,Object>> mapFactory)

Method Summary

Modifier and Type	Method and Description
void	cancel()
void	cancel(K key)
void	onCompleted()
void	onError(Throwable t)
void	onNext(T t)
void	requestMore(long n)
void	setProducer(rx.Producer s)

Methods inherited from class rx.Subscriber

add, isUnsubscribed, onStart, request, unsubscribe

Methods inherited from class java.lang.Object

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

Constructor Detail

GroupBySubscriber

public GroupBySubscriber(rx.Subscriber<? super rx.observables.GroupedObservable<K,V>> actual,
                         rx.functions.Func1<? super T,? extends K> keySelector,
                         rx.functions.Func1<? super T,? extends V> valueSelector,
                         int bufferSize,
                         boolean delayError,
                         rx.functions.Func1<rx.functions.Action1<K>,Map<K,Object>> mapFactory)

Method Detail

setProducer

public void setProducer(rx.Producer s)

Overrides:

setProducer in class rx.Subscriber<T>

onNext

public void onNext(T t)

onError

public void onError(Throwable t)

onCompleted

public void onCompleted()

requestMore

public void requestMore(long n)

cancel

public void cancel()

cancel

public void cancel(K key)