如何组合单声道和流量作为参数来创建新的单声道？

Question

我的REST控制器方法应该返回Mono，它必须由两个并行请求构建到另一个web服务，并处理它们的响应，其中一个请求返回Mono，另一个请求返回Flux

如何将单声道的响应与熔剂的响应结合起来进行处理？

@Document
@Data
@AllArgsConstructor
@NoArgsConstructor
public class ClassModel {

    @Id
    private String id;
    private String roomNr;
    private String className;
    private String teacherId;
    private List<String> studentIds;

    public void addStudentId(String studentId) {
        studentIds.add(studentId);
    }

}

public Mono<ClassModel> addRandomClassFull() {
    return Mono.zip(
        //request teacher microservice and return Mono - single teacher
        reactiveNetClient.addRandomTeacher(),
        //request students microservice and return Flux - list of students
        reactiveNetClient.addRandomStudents(10),
        (teacher, students) -> {
            ClassModel classModel = new ClassModel();
            classModel.setRoomNr("24B");
            classModel.setClassName(faker.educator().course());
            classModel.setTeacherId(teacher.getId());
            students.forEach(student -> classModel.addStudentId(student.getId());
            return classModel;
        }).flatMap(classRepository::save);
}

显然，控制器是错误的，因为:
1)Mono.zip()接受2个或更多的Mono，其中我有Mono和Flux-如何将它们组合起来？
2)也不确定:
students.foreach（student->classmodel.addstudentid(student.getid())；
是否正确？

有什么建议吗？

Answer 1

>

您可以将方法addrandomstudents()更改为返回mono

您可以在flux 上使用collectlist()，它将返回mono ，然后在addstudents()中将student对象转换为ID。

public Mono<ClassModel> addRandomClassFull() {
    return Mono.zip(
        reactiveNetClient.addRandomTeacher(),
        reactiveNetClient.addRandomStudents(10).collectList(),
        (teacher, students) -> {
             ClassModel classModel = new ClassModel();
             classModel.setRoomNr("24B");
             classModel.setClassName(faker.educator().course());
             classModel.setTeacherId(teacher.getId());
             classModel.addStudents(students);
        return classModel;
    }).flatMap(classRepository::save);
}