Spring 5 Web Reactive - ¿Cómo podemos usar WebClient para recuperar datos transmitidos en un Flux?
La documentación actual de hitos (M4) muestra un ejemplo sobre cómo recuperar unMono
utilizandoWebClient
:
WebClient webClient = WebClient.create(new ReactorClientHttpConnector());
ClientRequest<Void> request = ClientRequest.GET("http://example.com/accounts/{id}", 1L)
.accept(MediaType.APPLICATION_JSON).build();
Mono<Account> account = this.webClient
.exchange(request)
.then(response -> response.body(toMono(Account.class)));
¿Cómo podemos obtener datos transmitidos (de un servicio que devuelvetext/event-stream
) en un Flux usando WebClient? ¿Admite la conversión automática de Jackson?
Así es como lo hice en un hito anterior, pero la API ha cambiado y ya no puedo encontrar cómo hacerlo:
final ClientRequest<Void> request = ClientRequest.GET(url)
.accept(MediaType.TEXT_EVENT_STREAM).build();
Flux<Alert> response = webClient.retrieveFlux(request, Alert.class)