Как я могу использовать Flux с помощью WebClient ⇐ JAVA

[Anonymous]

У меня есть этот контроллер:

Код: Выделить всё

@GetMapping(value = "/stream")
public Flux stream() {
...
return webClient.get().uri(builder.buildAndExpand(parametres).toUriString())
.header(HttpHeaders.CONTENT_TYPE, TEXT_CSV).retrieve().bodyToFlux(DataBuffer.class);
}
}

Когда я вызвал эту конечную точку с помощью PostMan, я получил такой ответ:

Код: Выделить всё

[
{
"nativeBuffer": {
"direct": true,
"readOnly": false,
"contiguous": true,
"readable": true,
"writable": false
},
"allocated": true
},
...

Мой вопрос: как я могу использовать этот эндоинт с помощью веб-клиента, чтобы прочитать содержимое потока. Или, возможно, контроллер неисправен?
Я попробовал это, но это не работает:

Код: Выделить всё

 Flux fluxDataBuffer= webClient.get()
.uri("http://localhost:8080/stream")
.retrieve()
.bodyToFlux(DataBuffer.class);

DataBufferUtils.write(fluxDataBuffer, Paths.get("test.txt"),
StandardOpenOption.CREATE)
.share().block();

Спасибо за помощь


Подробнее здесь: https://stackoverflow.com/questions/707 ... -webclient