将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);