HttpClient Feeding Reactor с испускаемыми предметами из Flux - PullRequest
Новая
       31

HttpClient Feeding Reactor с испускаемыми предметами из Flux

0 голосов
/ 05 июня 2019

Создает ли новый экземпляр HttpClient каждый раз, когда запрос должен быть сделан облегченной операцией / и идиоматическим подходом в реакторе-нетто при совместном использовании одного и того же поставщика соединений?

Скажем, у меня есть поток пользователей, и для каждого пользователя приложение делает запрос к услуге: 

Flux.fromStream(Stream.generate(userRepository::take))
    .take(getDuration())
    .parallel()
    .runOn(Schedulers.elastic())
    .doOnTerminate(this::notifyAwaiting)
    .flatMap(user -> HttpClient
     .create(someProvider)
     .headers((h) -> setUserOnHeader(h, user))
     .get()
     .response())
    .subscribe(this::dispatch);

Будет ли этот подход создавать новый пул соединений для каждого пользователя?

...