Reactor - retry based on item field value

Question

I'm using a spring boot application with Webflux.

I need to retry the request if i get some error, but also, I need to check if an object property is true. This property is a boolean to check if i can retry.

Example:

webClient
        .post()
        .uri(object.getUrl())
        .body(BodyInserters.fromValue(docRequest))
        .retrieve()
        .bodyToMono(Document.class)
        .retry()
        .filter(e -> object.isRetry())

i tried this way but the filter is not working.

There is any way to filter?

Answer 1

you could use the more advanced features of retryWhen

Never done this before, but reading the reference guide this might work:

.retryWhen(Retry.from(companion -> companion.filter(it -> object.isRetry())));