- // If recovery fails, try to remove all instances
- Flux<?> policiesDeletedInRic = this.a1ClientFactory.createA1Client(ric) //
- .flatMapMany(A1Client::deleteAllPolicies);
-
- Flux.merge(typesRecoveredForRic, policiesDeletedInRic) //
- .subscribe(x -> logger.debug("Brute recover: {}", x), //
+ Flux.concat(recoverTypes, deletePoliciesInRic) //
+ .subscribe(x -> logger.debug("Brute recover: " + x), //