Мое требование — выполнить тесты при создании отдельных токенов, поэтому необходим для работы с флюсом. Вызов REST работает, но, похоже, возникла проблема с пробелами.
Код: Выделить всё
Flux eventStream=
webClientBuilder
.clientConnector(new ReactorClientHttpConnector(httpClient))
.baseUrl(baseUrl)
.build()
.post()
.uri(uriBuilder -> uriBuilder.path(uri).queryParam("temperature", "0.3").build(llmType))
.accept(MediaType.TEXT_EVENT_STREAM).headers(httpHeaders -> httpHeaders.addAll(headers))
.bodyValue(body)
.retrieve()
.bodyToFlux(String.class);
List resultList=
eventStream
.doOnNext(event->{
log.info(event.toString()+" "+event.length());
})
.doOnComplete(() -> {
log.debug("Completed thread {}..................",id);
})
.collectList()
.block();
log.info(String.join("",resultList));
Ожидается
"Конечно! Вот очаровательный и живой детский стишок, призванный очаровывать и развлекать тех, кто его читает..."
Подробнее здесь: https://stackoverflow.com/questions/792 ... hitespaces
Мобильная версия