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 <K> Observable<GroupedObservable<K,T>>
Observable. groupBy(Func1<? super T,? extends K> keySelector)
Groups the items emitted by anObservable
according to a specified criterion, and emits these grouped items asGroupedObservable
s.<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.<K,R>
Observable<GroupedObservable<K,R>>Observable. groupBy(Func1<? super T,? extends K> keySelector, Func1<? super T,? extends R> elementSelector, Func1<Action1<K>,java.util.Map<K,java.lang.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.operators Modifier and Type Class Description (package private) static class
OperatorGroupBy.GroupedUnicast<K,T>
Fields in rx.internal.operators with type parameters of type GroupedObservable Modifier and Type Field Description (package private) Subscriber<? super GroupedObservable<K,V>>
OperatorGroupBy.GroupBySubscriber. actual
(package private) java.util.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, java.util.Queue<?> q)
(package private) void
OperatorGroupBy.GroupBySubscriber. errorAll(Subscriber<? super GroupedObservable<K,V>> a, java.util.Queue<?> q, java.lang.Throwable ex)
Constructor parameters in rx.internal.operators with type arguments of type GroupedObservable 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>,java.util.Map<K,java.lang.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 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.
-