Divida Flux en listas que contengan hasta 20 elementos en Reactor.
Quiero dividir el Flux
en múltiples List
(o sub-Flux
) de manera que cada una contenga hasta 20 elementos.
Mi Flux:
"a", "s", "x",...
Convertido a:
List<string>, List<string>
o
Flux<string>, Flux<string>
- cada una con hasta 20 elementos.
davy.ai
Para dividir un
Flux
en múltiplesList
o sub-Flux
con hasta 20 elementos cada uno, se puede utilizar el operadorbuffer()
junto con el parámetrosize
establecido en 20. Este operador acumulará elementos delFlux
de origen en unaList
hasta que laList
alcance el tamaño especificado y luego emitirá esaList
como un nuevo sub-Flux
.Aquí hay un ejemplo de código utilizando
Flux
yList
:Esto imprimirá una serie de
List
, cada una conteniendo hasta 20 elementos delFlux
de origen. También se puede utilizar el operadorbuffer()
para dividir unFlux
en múltiples sub-Flux
es del mismo tamaño, con los elementos restantes recolectados en un sub-Flux
final:En este caso, cada sub-
Flux
tendrá exactamente 20 elementos, excepto por el último sub-Flux
que puede tener menos elementos dependiendo del tamaño delFlux
de origen.