遍历 Flux <T> 并使用 Webclient 获取数据

Question

我正在尝试从另一个微服务中获取数据。假设您有三个微服务：State、School 和 Student。您通过来自 SchoolRepository 的 stateId 获得 Flux，并且对于每个 School，您通过 webclient 调用 Student 微服务，该 Webclient 返回 Flux 并将其设置为 Flux。很快，我想做的是：

public Flux<School> getBySchool(Long stateId){

        Flux<School> schoolList=schoolRepository.findByStateId(stateId);
        //And for each school I want to do this
                Flux<Student> studentsfound=webClient.get().uri("bla bla bla"+school.getSchoolId).exchange().flatMapMany(response->response.bodyToFlux(Student.class));
                //I have a List<Student> entity in School domain, so I want Flux<Student> --> List<Student> and add it to School. Something like school.setStudentList(studentListReturned).
        //And then return Flux<Stundent>
}

如何遍历 Flux ，获得 Flux 后如何将其添加到适当的 Flux ？提前谢谢你。

更新

解决方案

非常感谢@K.Nicholas。我能够解决以下问题，但欢迎使用更优雅的解决方案。我在控制器中订阅了 schoolList，因为我必须将 Flux 从服务层返回到控制器层。

public Flux<School> getBySchoolWithStudents(Long stateId) {
    Flux<School> schoolList = schoolRepository.findByStateId(stateId);
    return schoolList.flatMap(school -> {
        Flux<Student> studentFlux = webClientBuilder.build().get().uri(REQUEST_URI + school.getSchoolId()).exchange().flatMapMany(response -> response.bodyToFlux(Student.class));
        return studentFlux.collectList().map(list -> {
            school.setStudentList(list);
            return school;
        });
    });
}

Answer 1

编辑：第二次尝试。所以，没有什么特别的，我能看到。使用collectList 方法并在map 函数中分配它。 map 函数返回范围内的学校对象。我必须进行一些调试以确保我的类正确支持序列化/反序列化。

    WebClient.create().get().uri(URI.create("http://localhost:8082/ss/school?state=CA"))
    .accept(MediaType.APPLICATION_JSON)
    .exchange()
    .flatMapMany(cr->cr.bodyToFlux(School.class))
    .flatMap(school->{
        return WebClient.create().get().uri(URI.create("http://localhost:8081/ss/student?school="+school.getName()))
        .accept(MediaType.APPLICATION_JSON)
        .exchange()
        .flatMapMany(crs->crs.bodyToFlux(Student.class))
        .collectList()
        .map(sl->{
            school.setStudents(sl);
            return school;
        });
    })
    .subscribe(System.out::println);