Попытка понять, как Spring WebClient обрабатывает соединения между коллегами. /> [D6B705E1] Ответ 200 OK
[d6b705e1] сигнал отменить (для закрытия соединения) < /p>
public WebClient webClient(WebClient.Builder builder) {
return builder
.baseUrl(config.getBaseurl())
.clientConnector(new ReactorClientHttpConnector(
HttpClient.create()
.tcpConfiguration(tcpClient -> tcpClient.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, timeout))
.secure(spec -> spec.sslContext(SslContextBuilder.forClient()))
))
.build();
}
Flux getIds() { ... }
Flux getResponses() {
// here as many open and close connection as the return stream getIds
return getIds().flatMap(... // client.retrieve().bodyToMono(Reponse.class));
}
Подробнее здесь: https://stackoverflow.com/questions/626 ... the-stream
