Блог

Есть Flux<DataBuffer> . В чем заключается естественный способ его преобразования Mono<byte[]> ?

 Mono<byte[]> mergeDataBuffers(Flux<DataBuffer> flux){
  // ?
}
 

Используйте org.springframework.core.io.buffer.DataBufferUtils для объединения буферов данных из Flux<DataBuffer> в один DataBuffer , а затем считайте этот буфер в массив байтов.

 
    Mono<byte[]> mergeDataBuffers(Flux<DataBuffer> dataBufferFlux) {
        return DataBufferUtils.join(dataBufferFlux)
                .map(dataBuffer -> {
                    byte[] bytes = new byte[dataBuffer.readableByteCount()];
                    dataBuffer.read(bytes);
                    DataBufferUtils.release(dataBuffer);
                    return bytes;
                });
    }
 

При этом обязательно учитывайте использование памяти, так как при таком подходе все данные будут загружены в память дважды (один раз в буферы данных, а затем снова при копировании в byte[] ).