Uses of Class
rx.observables.GroupedObservable
Packages that use GroupedObservable
Package
Description
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
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 GroupedObservableModifier and TypeMethodDescriptionfinal <K> Observable
<GroupedObservable<K, T>> Groups the items emitted by anObservable
according to a specified criterion, and emits these grouped items asGroupedObservable
s.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 anObservable
according to a specified criterion, and emits these grouped items asGroupedObservable
s.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 anObservable
according to a specified criterion, and emits these grouped items asGroupedObservable
s. -
Uses of GroupedObservable in rx.internal.operators
Subclasses of GroupedObservable in rx.internal.operatorsModifier and TypeClassDescription(package private) static final class
Fields in rx.internal.operators with type parameters of type GroupedObservableModifier and TypeFieldDescription(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 GroupedObservableModifier and TypeMethodDescriptionSubscriber
<? 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 -
Uses of GroupedObservable in rx.observables
Methods in rx.observables that return GroupedObservableModifier and TypeMethodDescriptionstatic <K,
T> GroupedObservable <K, T> GroupedObservable.create
(K key, Observable.OnSubscribe<T> f) Returns an Observable that will execute the specified function when aSubscriber
subscribes to it.static <K,
T> GroupedObservable <K, T> GroupedObservable.from
(K key, Observable<T> o) Converts anObservable
into aGroupedObservable
with a particular key.