CODEWITHSUNDEEP
kotlinproject-reactorreactive-streams
Dariusz Bacinski
Dariusz Bacinski

Reputation: 8670

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

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.

Upvotes: 12

Views: 21198

Answers (1)

tynn
tynn

Reputation: 39843

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

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

Upvotes: 27

Related Questions