使用阻塞运算符,我可以这样做:
valjust:Mono
但它是在声明时执行的,声明并不正确。
Flux的方法是collectList()与Rx中的toList()一样。
Flux
collectList()
toList()
val just: Mono<List<MyObject>> = flux.collectList()