Skip failures in SmallRye Mutiny when it calls to a Rest API in Quarkus and reactive programming

[allanh1193cr]

I have a method to call an external rest API and save the response from that API in a list and return the list to continue the process. Basically, this is what I'm doing

I have a request list to call to the rest API n times. I iterate over that list and call the rest API one by one.

If the call to the rest API fails and the error type is a httpStatusCode 500 I will retry 3 times the call to the rest API. If the call is still failing. I will send the request to a DLQ and the idea is to continue with the next request**(here is the problem)**.

I save the response of the call to the rest API using a map

Convert to list the responses and return a Uni.

public Uni<List<Result>> myMethod(final Map<String, ObjectRequest> objectRequest) {
     final String accessToken = forgeService.generateAuthToken();
     List<Uni<Result>> resultOfRequest = objectRequest.values().stream()
             .flatMap(listOfObjects -> listOfObjects().stream())
             .map(request -> serviceRestClient.postAPI(request)
                     .onFailure(ex -> ex instanceof WebApplicationException && isRetryableStatus(((WebApplicationException) ex).getResponse().getStatus()))
                     //TODO I WANT TO LOG HERE THAT A ERROR HAPPENED AND I WILL RETRY TO SEND THE DEBIT REQUEST TO WMS
                     .retry().withBackOff(Duration.ofMillis(100),
                             Duration.ofSeconds(200)).withJitter(0.2).atMost(3)
                     .onFailure()
                     .recoverWithItem(() -> {//TODO This should be recoverWithUNI ? HOW CAN I CONTINUE WITH THE NEXT ITERATION?
                         sendRequestToDLQ(request);
                         return null; //I DON'T HAVE A RESPONSE FROM THE API, WHAT SHOULD I RETURN HERE?
                     })
                     .map(response -> Result.builder()
                             .id(response.id())
                             .value(request.value))
                             .build())
             .toList();
     Log.infof("Results of the call to the API %s", objectRequest);
     return Uni.join().all(resultOfRequest)
             .andCollectFailures()
             .invoke(res -> Log.trace("Charging acknowledgement received"));
 }

This is the code I have created, I tested and the retry is working, I'm sending the request to the DLQ successfully but the issue is when I map the response(it does not exists). How can I continue to the next iteration in case of the retry fails the three attempts without call to .map operation?