我正在进行spring webflux文件上传。我想从控制器上传文件到amazon S3 bucket上。在控制器中,我收到了以下物体
org.springframework.http.codec.multipart.FilePart
从文件部分。content()我可以
reactor.core.publisher.Flux<org.springframework.core.io.buffer.DataBuffer>
我的问题是如何转换这个通量
Flux<java.nio.ByteBuffer>
你可以简单地使用组织。springframework。果心io。缓冲器DataBuffer#asByteBuffer():
Flux<java.nio.ByteBuffer> buffers = filePart.content()
.map(DataBuffer::asByteBuffer);
使用spring 5,对于reactor,我们有以下需求。 什么方法可以转换单声道
我在玩r2dc for spring boot java应用程序。 我在想,如果可能的话,可以把通量转换成Mono来进行某种计算。 伪示例:
我的数据库正在返回Flux,我需要将其转换为Mono 如果调用方方法的返回类型只有Mono,我可以很容易地将其映射如下,但由于它是Mono //期望将水果的流量转换为水果列表的单声道并返回给调用者 }
我有一个方法,可以尝试使用WebClient返回Mono 它可以返回我期望的结果。然后我尝试创建另一个方法来支持列表作为参数 但这一次返回一个奇怪的结果。 我是反应式编程新手,将流和单声道结合起来,然后转换为流量的正确方法是什么?
鉴于我有一个
我们使用的是Spring数据,当我们调用时,我们收到的是