Uses of Class
rx.observables.GroupedObservable

Packages that use GroupedObservable

Package	Description
rx	Base reactive classes: Observable, Single and Completable; base reactive consumers; other common base interfaces.
rx.internal.operators	Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.
rx.observables	Classes extending the Observable base reactive class, synchronous and asynchronous event generators.

Uses of GroupedObservable in rx

Methods in rx that return types with arguments of type GroupedObservable

Modifier and Type	Method	Description
final <K> Observable<GroupedObservable<K,T>>	Observable.groupBy(Func1<? super T,? extends K> keySelector)	Groups the items emitted by an Observable according to a specified criterion, and emits these grouped items as GroupedObservables.
final <K, R> Observable<GroupedObservable<K,R>>	Observable.groupBy(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends R> elementSelector)	Groups the items emitted by an Observable according to a specified criterion, and emits these grouped items as GroupedObservables.
final <K, R> Observable<GroupedObservable<K,R>>	Observable.groupBy(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends R> elementSelector, Func1<Action1<K>,Map<K,Object>> evictingMapFactory)	Groups the items emitted by an Observable according to a specified criterion, and emits these grouped items as GroupedObservables.

Uses of GroupedObservable in rx.internal.operators

Subclasses of GroupedObservable in rx.internal.operators

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

Fields in rx.internal.operators with type parameters of type GroupedObservable

Modifier and Type	Field	Description
(package private) final Subscriber<? super GroupedObservable<K,V>>	OperatorGroupBy.GroupBySubscriber.actual
(package private) final Queue<GroupedObservable<K,V>>	OperatorGroupBy.GroupBySubscriber.queue

Method parameters in rx.internal.operators with type arguments of type GroupedObservable

Modifier and Type	Method	Description
Subscriber<? super T>	OperatorGroupBy.call(Subscriber<? super GroupedObservable<K,V>> child)
(package private) boolean	OperatorGroupBy.GroupBySubscriber.checkTerminated(boolean d, boolean empty, Subscriber<? super GroupedObservable<K,V>> a, Queue<?> q)
(package private) void	OperatorGroupBy.GroupBySubscriber.errorAll(Subscriber<? super GroupedObservable<K,V>> a, Queue<?> q, Throwable ex)

Constructor parameters in rx.internal.operators with type arguments of type GroupedObservable

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

Uses of GroupedObservable in rx.observables

Methods in rx.observables that return GroupedObservable

Modifier and Type	Method	Description
static <K, T> GroupedObservable<K,T>	GroupedObservable.create(K key, Observable.OnSubscribe<T> f)	Returns an Observable that will execute the specified function when a Subscriber subscribes to it.
static <K, T> GroupedObservable<K,T>	GroupedObservable.from(K key, Observable<T> o)	Converts an Observable into a GroupedObservable with a particular key.