将 Flux<DataBuffer> 转换为 Flux<ByteBuffer>

Question

我正在处理 spring webflux 文件上传。从控制器我想将文件上传到亚马逊 S3 存储桶上。所以在控制器中我收到了以下对象

org.springframework.http.codec.multipart.FilePart

从FilePart.content()我可以得到

reactor.core.publisher.Flux<org.springframework.core.io.buffer.DataBuffer>

我的问题是如何将 Flux<DataBuffer> 转换为 Flux<ByteBuffer>。我的意思是进入以下对象

Flux<java.nio.ByteBuffer>

Answer 1

您可以简单地使用org.springframework.core.io.buffer.DataBuffer#asByteBuffer():

Flux<java.nio.ByteBuffer> buffers = filePart.content()
    .map(DataBuffer::asByteBuffer);