<@NonNull K> @NonNull Flowable<GroupedFlowable<K,T>> |
Flowable.groupBy(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector) |
Groups the items emitted by the current Flowable according to a specified criterion, and emits these
grouped items as GroupedFlowable s.
|
<@NonNull K> @NonNull Flowable<GroupedFlowable<K,T>> |
Flowable.groupBy(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
boolean delayError) |
Groups the items emitted by the current Flowable according to a specified criterion, and emits these
grouped items as GroupedFlowable s.
|
<@NonNull K,@NonNull V> @NonNull Flowable<GroupedFlowable<K,V>> |
Flowable.groupBy(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
@NonNull Function<? super @NonNull T,? extends @NonNull V> valueSelector) |
Groups the items emitted by the current Flowable according to a specified criterion, and emits these
grouped items as GroupedFlowable s.
|
<@NonNull K,@NonNull V> @NonNull Flowable<GroupedFlowable<K,V>> |
Flowable.groupBy(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
@NonNull Function<? super @NonNull T,? extends @NonNull V> valueSelector,
boolean delayError) |
Groups the items emitted by the current Flowable according to a specified criterion, and emits these
grouped items as GroupedFlowable s.
|
<@NonNull K,@NonNull V> @NonNull Flowable<GroupedFlowable<K,V>> |
Flowable.groupBy(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
@NonNull Function<? super @NonNull T,? extends @NonNull V> valueSelector,
boolean delayError,
int bufferSize) |
Groups the items emitted by the current Flowable according to a specified criterion, and emits these
grouped items as GroupedFlowable s.
|
<@NonNull K,@NonNull V> @NonNull Flowable<GroupedFlowable<K,V>> |
Flowable.groupBy(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
@NonNull Function<? super @NonNull T,? extends @NonNull V> valueSelector,
boolean delayError,
int bufferSize,
@NonNull Function<? super Consumer<java.lang.Object>,? extends java.util.Map<@NonNull K,java.lang.Object>> evictingMapFactory) |
Groups the items emitted by the current Flowable according to a specified criterion, and emits these
grouped items as GroupedFlowable s.
|