Никто не подскажет, если есть мостик между реактором (Mono/Flux) и

Question

Никто не подскажет, если есть мостик между реактором (Mono/Flux) и

корутинами, то обязательно ли при создании WebClient запросов надо освобождать тело? Или и так сойдёт?

/**
* Release the body of this response.
* @return a completion signal
* @since 5.2
* @see org.springframework.core.io.buffer.DataBufferUtils#release(DataBuffer)
*/
Mono<Void> releaseBody();

#backend #java #programming #russian

0

07.10.2020

14 ответов

21 просмотр

Vladimir Petraković

Зависит от мостика

0

07.10.2020

Aleksandr Автор вопроса

Vladimir Petraković
Зависит от мостика

Мостик в моём случае - kotlinx.coroutines.reactive.awaitFirst

0

07.10.2020

Aleksandr Автор вопроса

Ilya Grudsky
Ты же вычитываешь Body? Если да — оно само должно ...

А где это написано, не подскажите? 😁

0

07.10.2020

Vladimir Petraković

Aleksandr
Мостик в моём случае - kotlinx.coroutines.reactive...

А у чего этот метод дёргается? Если там ответ, который ещё полностью не скачан, то тело надо отдельно использовать или освобождать.

0

07.10.2020

Ilya Grudsky

Aleksandr
А где это написано, не подскажите? 😁

Там внутри bodyToMono есть drainResponse

0

07.10.2020

Ilya Grudsky

Ilya Grudsky
Там внутри bodyToMono есть drainResponse

который делает release

0

07.10.2020

Aleksandr Автор вопроса

Vladimir Petraković
А у чего этот метод дёргается? Если там ответ, кот...

Ну смотрите, логика следующего характера. 1) Выполняется post запрос в духе .post() .uri { it.build(someMapOfParams) } .body(BodyInserters.fromObject(someBodyProps)) .exchange() .awaitFirst() 2) Идёт проверка бизнес ошибок в духе val statusCode = response.statusCode() when { statusCode.is5xxServerError -> throw SomeErrorException() else -> aggregateLogErrorBody(response, statusCode) } 3) Собстна пункт 1 оборачивается в try-catch, но сейчас не об этом. Если таки произошла ошибка и она не 500ка, то надо вытащить тело ошибки val errorResponse = response.bodyToMono(String::class.java).awaitFirst() Ну вот и после этого я состовляю ошибку с помощью стинги

0

07.10.2020

Ilya Grudsky

Aleksandr
Ну смотрите, логика следующего характера. 1) Выпо...

в таком случае тебе самому надо делать release, да.

0

07.10.2020

Aleksandr Автор вопроса

Ilya Grudsky
в таком случае тебе самому надо делать release, да...

А как это определяется? Можно подробнее пж-та

0

07.10.2020

Vladimir Petraković

Aleksandr
Ну смотрите, логика следующего характера. 1) Выпо...

Если вы большие файлы не тягаете (не похоже), проще ответ буферизовать сразу и не думать об этом больше. Я не знаю, как это там делается, но такая возможность наверняка есть.

0

07.10.2020

Ilya Grudsky

Aleksandr
А как это определяется? Можно подробнее пж-та

Я не особо вникал (так как занят был). У тебя есть bodyToMono который делает release. Так что всё ок.

0

07.10.2020

Aleksandr Автор вопроса

Ilya Grudsky
Я не особо вникал (так как занят был). У тебя есть...

Вероятно ситуация зависит от версии, если верить этому ответу https://stackoverflow.com/questions/55671246/how-to-properly-drain-release-response-body-from-webflux-client/55672095

0

07.10.2020

Ilya Grudsky

Aleksandr
Вероятно ситуация зависит от версии, если верить э...

Понятия не имею, я просто открыл сорсы webClient и глянул что там и как.

0

07.10.2020

Ilya Grudsky · Accepted Answer

Ilya Grudsky

Ты же вычитываешь Body? Если да — оно само должно release сделать после вычитки.

0

07.10.2020

170 похожих чатов

Никто не подскажет, если есть мостик между реактором (Mono/Flux) и

14 ответов

Похожие вопросы