Is it possible to get the first element from flux without converting flux into stream?

java spring-webflux project-reactor reactive
akreddy.21 picture akreddy.21 · Mar 5, 2019 · Viewed 7.3k times · Source

Is it possible to get the first element from flux without converting flux into stream?

Answer

Simon Baslé picture Simon Baslé · Mar 6, 2019

Alternatively to take(1), if you need a Mono<T> that represents the first element of the Flux<T> you can use .next().

Or if you need the i-th element, use .elementAt(i) (must be sure that such an element exists though, unlike take and next which just return an empty publisher if not enough elements).

Related questions

How to correctly read Flux<DataBuffer> and convert it to a single inputStream

I'm using WebClient and custom BodyExtractorclass for my spring-boot application WebClient webLCient = WebClient.create(); webClient.get() .uri(url, params) .accept(MediaType.APPLICATION.XML) .exchange() .flatMap(response -> { return response.body(new BodyExtractor()); }) BodyExtractor.java @Override public Mono<T&…

Read More
block()/blockFirst()/blockLast() are blocking error when calling bodyToMono AFTER exchange()

I am trying to use Webflux to stream a generated file to another location, however, if the generation of the file ran into an error, the api returns success, but with a DTO detailing the errors while generating the file …

Read More
Spring WebFlux, how can I debug my WebClient POST exchange?

I am having trouble understanding what I've done wrong in constructing my WebClient request. I would like to understand what the actual HTTP request looks like. (e.g., dumping the raw request to console) POST /rest/json/send HTTP/1.1 Host: …

Read More