类的使用
reactor.core.publisher.GroupedFlux

使用GroupedFlux的程序包

程序包	说明
reactor.core.publisher	Provide main Reactive APIs in Flux and Mono, as well as various helper classes, interfaces used in the composition API, variants of Flux and operator-building utilities.

reactor.core.publisher中GroupedFlux的使用

返回变量类型为GroupedFlux的类型的reactor.core.publisher中的方法

限定符和类型	方法和说明
<K> Flux<GroupedFlux<K,T>>	Flux.groupBy(java.util.function.Function<? super T,? extends K> keyMapper) Divide this sequence into dynamically created Flux (or groups) for each unique key, as produced by the provided keyMapper Function.
<K,V> Flux<GroupedFlux<K,V>>	Flux.groupBy(java.util.function.Function<? super T,? extends K> keyMapper, java.util.function.Function<? super T,? extends V> valueMapper) Divide this sequence into dynamically created Flux (or groups) for each unique key, as produced by the provided keyMapper Function.
<K,V> Flux<GroupedFlux<K,V>>	Flux.groupBy(java.util.function.Function<? super T,? extends K> keyMapper, java.util.function.Function<? super T,? extends V> valueMapper, int prefetch) Divide this sequence into dynamically created Flux (or groups) for each unique key, as produced by the provided keyMapper Function.
<K> Flux<GroupedFlux<K,T>>	Flux.groupBy(java.util.function.Function<? super T,? extends K> keyMapper, int prefetch) Divide this sequence into dynamically created Flux (or groups) for each unique key, as produced by the provided keyMapper Function.
Flux<GroupedFlux<java.lang.Integer,T>>	ParallelFlux.groups() Exposes the 'rails' as individual GroupedFlux instances, keyed by the rail index (zero based).

类型变量类型为GroupedFlux的reactor.core.publisher中的方法参数

限定符和类型	方法和说明
<U> ParallelFlux<U>	ParallelFlux.transformGroups(java.util.function.Function<? super GroupedFlux<java.lang.Integer,T>,? extends org.reactivestreams.Publisher<? extends U>> composer) Allows composing operators off the groups (or 'rails'), as individual GroupedFlux instances keyed by the zero based rail's index.