Reactor Flux<MyObject> to Mono<List<MyObject>>

kotlin project-reactor reactive-streams
Dariusz Bacinski picture Dariusz Bacinski · May 18, 2017 · Viewed 7.8k times · Source

How can I convert Flux<MyObject> directly to Mono<List<MyObject>> ?

I am looking for equivalent of Single<List<MyObject>> single = observable.toList() from RxJava.

With blocking operator I can do it like this:

val just: Mono<List<MyObject>> = Mono.just(flux.toIterable().toList())

But it is executed at the time of declaration which doesn't seam to be right.

Answer

tynn picture tynn · May 18, 2017

Flux has the method collectList() doing just the same like toList() in Rx.

val just: Mono<List<MyObject>> = flux.collectList()

Related questions

How to log request and response bodies in Spring WebFlux

I want to have centralised logging for requests and responses in my REST API on Spring WebFlux with Kotlin. So far I've tried this approaches @Bean fun apiRouter() = router { (accept(MediaType.APPLICATION_JSON) and "/api").nest { "/user".nest { GET("/", userHandler::…

Read More
How to check if Mono is empty?

I'm developing a app with Spring Boot 2.0 and Kotlin using the WebFlux framework. I want to check if a user id exits before save a transaction. I'm stucked in a simple thing like validate if a Mono is empty. fun …

Read More
WebFlux functional: How to detect an empty Flux and return 404?

I'm having the following simplified handler function (Spring WebFlux and the functional API using Kotlin). However, I need a hint how to detect an empty Flux and then use noContent() for 404, when the Flux is empty. fun findByLastname(request: ServerRequest): …

Read More