如何将一个流量的每个元素与另一个需要元素属性的流量组合在一起

Question

我有一个关于Spring WebFlux和Reactor的问题。我试图编写一个简单的场景，其中在GETendpoint中，我返回一个表示实体的DTO流，这些实体中的每一个都有一个表示另一个实体的其他DTO的集合。以下是详细信息。

我有两个实体，Person和Song，定义如下：

@Data
public class Person {
    @Id
    private Long id;
    private String firstName;
    private String lastName;
}

@Data
public class Song {
    @Id
    private Long id;
    private String title;
    private Long authorId;
}

这些实体由以下DTO表示：

@Data
public class SongDTO {
    private Long id;
    private String title;
    public static SongDTO from(Song s) {
        // converts Song to its dto
    }
}

@Data
public class PersonDTO {
    private Long id;
    private String firstName;
    private String lastName;
    private List<SongDTO> songs = new ArrayList<>();
    public static PersonDTO from(Person p, List<Song> songs) {
        // converts person to its dto, invokes SongDTO.from on each song 
        // and adds the result to personDTO.songs
    }
}

我的服务（为了简洁起见，这里没有显示）确实返回Mono和flux。然后我就有了以下RESTController：

@RestController
@RequestMapping("/people")
public class PersonController {
    @Autowired PersonService people;
    @Autowired SongService songs;
    
    @GetMapping(produces = MediaType.APPLICATION_JSON_VALUE)
    public Flux<PersonDTO> findAllPeople() {
        return people.findAll()
                .map(person -> PersonDTO.from(person, /* HERE */ new ArrayList<>()));
        // TODO: find the songs of each author reactively and put the results in personDTO.songs
    }
}

现在，我的问题是：我如何

• 调用songs.findbyauthorid(Person.getid())
• 将返回的流量转换为songdto列表
• 在PersonDTO中以反应的方式设置列表？

我试图查看Reactor的文档，但没有成功，搜索了其他StackOverflow问题和整个互联网，但没有找到任何东西，很可能是因为我不确定如何表达我的搜索。有人能提供提示吗？

谢谢。

Answer 1

您可以使用FlatMap+Map:

people.findAll()
      .flatMap(person -> songs.findByAuthorId(person.getId())
                              .collectList()
                              .map(songList -> PersonDTO.from(person, songList)));