[WebFlux] inference variable V

Version imprimable

Bonjour,

Je fais appel à deux microservices avec WebClient
J'ai deux méthodes (test1 et test2) dans mon service pour tester unitairement les appels. Ces deux méthodes fonctionnent

Je souhaiterai faire appel au premier "ouvrageClient" pour récupérer un Flux d'Ouvrage et à partir de ce flux d'ouvrage faire appel à l'autre WebClient "operationClient" pour récupérer un Flux d'opération.

Par contre, j'ai une erreur à la compilation dans la méthode getRelatedOperations

Code:

1
2
3
4
 
java: incompatible types: inference variable V has incompatible bounds
    equality constraints: com.rte.prisk.core.operation.dto.query.OperationLightDto
    lower bounds: reactor.core.publisher.Flux<com.rte.prisk.core.operation.dto.query.OperationLightDto>

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
 
public class RelatedOperationService {
 
    private  OperationClient operationClient;
    private  OuvrageClient ouvrageClient;
 
    public Flux<OperationLightDto> getRelatedOperations(Long[] ouvrageIds){
        final Flux<OuvrageDto> ouvrageFlux = ouvrageClient.getRelatedOuvrages(ouvrageIds); //équivaut à la méthode test1
        return ouvrageFlux
                .map(ouvrageDto -> {
                    return operationClient.getRelatedOperations(ouvrageDto.getId());// équivaut à la méthode test2
                });
    }
 
    public Flux<OuvrageDto> test1(Long ouvrageIds[]){
        return  ouvrageClient.getRelatedOuvrages(ouvrageIds);
    }
 
    public Flux<OperationLightDto> test2(Long ouvrageId){
        return operationClient.getRelatedOperations(ouvrageId);
    }
 
}

Avez-vous une idée pour cette erreur ?

Bien cordialement

12/10/2022, 14h09
lekonquerant

Bonjour,

est ce que le type retour de la méthode

Code:

operationClient.getRelatedOperations(ouvrageDto.getId())

correspond exactement à

Code:

Flux<OperationLightDto>

?
car l'erreur semble dire que l'objet OperationLightDto n'est pas le même

Bonjour,

merci pour la réponse

La méthode retourne bien un Flux<OperationLightDto>, d'où mon incompréhension

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
 
@Service
public class OperationClient {
 
    private final WebClient webClient;
 
    public OperationClient(WebClient.Builder builder) {
        this.webClient = builder.baseUrl("lb://operation-query-microservice/operation/").build();
    }
 
 
    public Flux<OperationLightDto> getRelatedOperations(Long ouvrageId){
        return webClient
                .get()
                .uri("related/{ouvrageId}",ouvrageId)
                .retrieve()
                .bodyToFlux(OperationLightDto.class)
                .subscribeOn(Schedulers.parallel());
    }
 
}

En modifiant, le code le retour la méthode operationClient.getRelatedOperations(ouvrageDto.getId()) retourne bien un Flux<OperationLightDto>

Code:

1
2
3
4
5
6
7
8
9
 
    public Flux<OperationLightDto> getRelatedOperations(Long[] ouvrageIds){
        final Flux<OuvrageDto> ouvrageFlux = ouvrageClient.getRelatedOuvrages(ouvrageIds); //= test1
        return ouvrageFlux
                .map(ouvrageDto -> {
                    Flux<OperationLightDto> op = operationClient.getRelatedOperations(ouvrageDto.getId());// = test2
                    return op;
                });
    }

Bonjour,

j'ai toujours mon erreur et je ne comprends pas pourquoi :

Code:

1
2
3
4
5
6
 
Required type:
Flux<OperationLightDto>
Provided:
Flux<Object>
no instance(s) of type variable(s) exist so that Flux<OperationLightDto> conforms to OperationLightDto inference variable V has incompatible bounds: equality constraints: OperationLightDto lower bounds: Flux<OperationLightDto>

Avez-vous un idée, svp ?