我是Project Reactor和R2DBC的新手。如何使用Spring Data R2DBC反应性存储库正确接收和合并Flux<Child>与Mono<Parent>？

父母：

@Table("parent")
public class Parent{

@Id
private Long id;
private String name;

@Transient
private Flux<Child> children;

ParentRepository：

interface ParentRepository extends ReactiveCrudRepository<Parent,Long> {

@Query()
Mono<Parent> findOneByName(String name);

孩子：

@Table("child")
public class Child{

@Id
private Long id;

ChildRepository：

interface ChildRepository extends ReactiveCrudRepository<Child,Long> {

@Query()
Flux<Child> findAllByParentId(Long parentId);

ParentPersistenceAdapter：

public Mono<Parent> findParent(String parentName) {
    return parentRepository.findOneByName(parentName)
      //how to invoke childRepository.findAllByParentId()
      //and set this Flux to Parent's Mono

}

我的解决方法是：

public Mono<Parent> findParent(String parentName) {
    return parentRepository.findOneByName(parentName)
      .map(parent -> {
            Flux<Child> children = childRepository.findAllByParentId(parent.getId())
            children.subscribe();
            return parent.setChildren(children );
        });      
}