Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
io.reactivex.internal.operators.flowable |
Modifier and Type | Method and Description |
---|---|
<K> Flowable<GroupedFlowable<K,T>> |
Flowable.groupBy(Function<? super T,? extends K> keySelector)
Groups the items emitted by a
Publisher according to a specified criterion, and emits these
grouped items as GroupedFlowable s. |
<K> Flowable<GroupedFlowable<K,T>> |
Flowable.groupBy(Function<? super T,? extends K> keySelector,
boolean delayError)
Groups the items emitted by a
Publisher according to a specified criterion, and emits these
grouped items as GroupedFlowable s. |
<K,V> Flowable<GroupedFlowable<K,V>> |
Flowable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector)
Groups the items emitted by a
Publisher according to a specified criterion, and emits these
grouped items as GroupedFlowable s. |
<K,V> Flowable<GroupedFlowable<K,V>> |
Flowable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
boolean delayError)
Groups the items emitted by a
Publisher according to a specified criterion, and emits these
grouped items as GroupedFlowable s. |
<K,V> Flowable<GroupedFlowable<K,V>> |
Flowable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
boolean delayError,
int bufferSize)
Groups the items emitted by a
Publisher according to a specified criterion, and emits these
grouped items as GroupedFlowable s. |
<K,V> Flowable<GroupedFlowable<K,V>> |
Flowable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
boolean delayError,
int bufferSize,
Function<? super Consumer<Object>,? extends Map<K,Object>> evictingMapFactory)
Groups the items emitted by a
Publisher according to a specified criterion, and emits these
grouped items as GroupedFlowable s. |
Modifier and Type | Method and Description |
---|---|
GroupedFlowable<K,V> |
FlowableGroupBy.GroupBySubscriber.poll() |
Modifier and Type | Method and Description |
---|---|
protected void |
FlowableGroupBy.subscribeActual(org.reactivestreams.Subscriber<? super GroupedFlowable<K,V>> s) |
Constructor and Description |
---|
GroupBySubscriber(org.reactivestreams.Subscriber<? super GroupedFlowable<K,V>> actual,
Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
int bufferSize,
boolean delayError,
Map<Object,io.reactivex.internal.operators.flowable.FlowableGroupBy.GroupedUnicast<K,V>> groups,
Queue<io.reactivex.internal.operators.flowable.FlowableGroupBy.GroupedUnicast<K,V>> evictedGroups) |
Copyright © 2018 JBoss by Red Hat. All rights reserved.