lucasqueiroz
03/11/2020, 8:14 PMnfrankel
03/11/2020, 9:00 PMnfrankel
03/11/2020, 9:00 PMlucasqueiroz
03/11/2020, 9:17 PMOdín del Río
03/12/2020, 3:42 PMOdín del Río
03/12/2020, 3:43 PMRobert
03/23/2020, 10:13 AMsuspend fun ClientResponse.asResponse(): ServerResponse =
status(statusCode())
.headers { headerConsumer -> headerConsumer.addAll(headers().asHttpHeaders()) }
.body(bodyToMono(DataBuffer::class.java), DataBuffer::class.java)
.retryWhen {
Retry.onlyIf { ctx: RetryContext<Throwable> -> (ctx.exception() as? WebClientResponseException)?.statusCode in retryableErrorCodes }
.exponentialBackoff(ofSeconds(1), ofSeconds(5))
.retryMax(3)
.doOnRetry { log.error("Retry for {}", it.exception()) }
)
.awaitSingle()
Robert
03/27/2020, 1:06 PM