将响应实体迁移到Mono

Question

在一个spring boot应用程序中，我用webclient给ms打了一个电话

响应实体响应 = webClient.post（） .uri（“/auth/login”） .body（Mono.just（loginRequest）， LoginDto.class） .retrieve（） .toEntity（LoginResponse.class） .block（）;

在我把角色放到一个集合中之后

Collection<? extends GrantedAuthority> authorities = response.getBody().getRoles().stream()
            .map(item -> new SimpleGrantedAuthority(item)).collect(Collectors.toList());

在我创建一个Mono返回后

Mono.just(new UsernamePasswordAuthenticationToken(username, password, authorities));

我修改了ms以返回Mono

有了这个变化，我不知道该改变什么

Mono<ResponseEntity<LoginResponse>> response = webClient.post()
            .uri("/auth/login")
            .body(Mono.just(loginRequest), LoginDto.class)
            .retrieve()
            .toEntity(LoginResponse.class);

Collection<? extends GrantedAuthority> authorities = response.getBody().getRoles().stream()
            .map(item -> new SimpleGrantedAuthority(item)).collect(Collectors.toList());

Mono.just(new UsernamePasswordAuthenticationToken(username, password, authorities));

Answer 1

使用flatMap以异步方式将某物映射到其他对象。

public Mono<UsernamePasswordAuthenticationToken> foobar() {
    Mono<ResponseEntity<LoginResponse>> response = webClient.post()
            .uri("/auth/login")
            .body(Mono.just(loginRequest), LoginDto.class)
            .retrieve()
            .toEntity(LoginResponse.class);

    return response.flatMap(response -> {
        Collection<? extends GrantedAuthority> authorities = response.getBody()
             .getRoles()
             .stream()
             .map(item -> new SimpleGrantedAuthority(item))
             .collect(Collectors.toList());
        return Mono.just(new UsernamePasswordAuthenticationToken(username, password, authorities));
    }
}