Spring 5 Web Reactive - Как мы можем использовать WebClient для извлечения потоковых данных в Flux?
Текущая документация Milestone (M4) показывает и пример того, как получитьMono
с помощьюWebClient
:
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)));
Как мы можем получить потоковые данные (от службы, которая возвращаетtext/event-stream
) в поток с использованием WebClient? Поддерживает ли он автоматическое преобразование Джексона?
Вот как я это делал в предыдущем шаге, но API изменился и больше не могу найти, как это сделать:
final ClientRequest<Void> request = ClientRequest.GET(url)
.accept(MediaType.TEXT_EVENT_STREAM).build();
Flux<Alert> response = webClient.retrieveFlux(request, Alert.class)