Mono对象而不是Mono<myPojo>

Question

好的，所以我有了下面的方法，但是我试图避免使用.block()，所以尝试实现Mono，但是得到了错误Required type: List<Mono<CatalogItem>> Provided:Mono<Object>

原码

@GetMapping("/user/{userId}")
public List<CatalogItem> getUserMoviesRating(@PathVariable String userId) {

    UserRating ratings = webClientBuilder.build()
            .get()
            .uri("http://localhost:8083/ratingsdata/users/" + userId)
            .retrieve()
            .bodyToMono(UserRating.class)
            .block();

    assert ratings != null;
    return ratings.getUserRating().stream().map(rating -> {

        Movies movie = webClientBuilder.build()
                .get()
                .uri("http://localhost:8082/movies/"  + rating.getMovieId())
                .retrieve()
                .bodyToMono(Movies.class)
                .block();

        assert movie != null;
        return new CatalogItem(movie.getName(), movie.getDesc(), rating.getRating());
    }).collect(Collectors.toList());
}}

我用非阻塞方式重构Mono的尝试

@GetMapping("/user/{userId}")
public List <Mono<CatalogItem>> getUserMoviesRating(@PathVariable String userId) {

    Mono<UserRating> ratings = webClientBuilder.build()
            .get()
            .uri("http://localhost:8083/ratingsdata/users/" + userId)
            .retrieve()
            .bodyToMono(UserRating.class);

    return ratings.map(userRating -> userRating.getUserRating().stream().map(rating -> {
        Mono<Movies> movies = webClientBuilder.build()
                .get()
                .uri("http://localhost:8082/movies/" + rating.getMovieId())
                .retrieve()
                .bodyToMono(Movies.class);
        return movies.map(m -> new CatalogItem(m.getName(), m.getDesc(), rating.getRating()));
    }).collect(Collectors.toList()));
}

Answer 1

将java8StreamAPI与反应堆发布程序结合起来并不是最佳的解决方案，因为这会降低代码的可读性，使它们的工作方式不同。您可以查看here获得更多详细信息，以防userRating.getUserRating()返回分级列表，您可以尝试使用此代码。

  public Mono <List<CatalogItem>> getUserMoviesRating(@PathVariable String userId) {

    Mono<UserRating> ratings = webClientBuilder.build()
        .get()
        .uri("http://localhost:8083/ratingsdata/users/" + userId)
        .retrieve()
        .bodyToMono(UserRating.class);

    return ratings.flatMapMany(userRating -> Flux.fromIterable(userRating.getUserRating()))
        .flatMap(rating->this.getMovie(rating.getMovieId()))
        .map(m -> new CatalogItem(m.getName(), m.getDesc(), rating.getRating()))
        .collectList();
  }
    
  private Mono<Movies> getMovie(String movieId){
    return webClientBuilder.build()
        .get()
        .uri("http://localhost:8082/movies/" + movieId)
        .retrieve()
        .bodyToMono(Movies.class);
  }