在响应流之间切换

Question

我试图在数据库中创建一个新记录，但是在我需要获取另一个记录并从中获取一些数据并将其设置为新记录之前

public Mono<Subject> create(Mono<Subject> subject) {
    return subject
            .flatMap(s -> subjectRepository.findById(s.getParentId()))
            .flatMap(parent ->
                    subject.doOnNext(child -> {
                        child.setParentId(parent.getId());
                        child.setCreatedDate(LocalDateTime.now());
                        child.setRoute(Utils.buildRoute(child, parent));
                    }))
            .flatMap(subjectRepository::insert);
}

我的错误是什么？如何纠正？

Answer 1

试试这个片段。

return subject
    .flatMap(s -> {
        return repository.findById(s.getParentId())
                .flatMap(p-> {
            s.setParentId(p.getId());
            s.setCreatedDate(LocalDateTime.now());
            s.setRoute(Utils.buildRoute(s, p));
            return repository.save(s);
        });
    });

Answer 2

主题。doOnNext从未订阅，因此从未实际执行。另外，doOn***运算符是“副作用”运算符，您不应该在这些运算符中实现业务逻辑或I/O操作。你可以试试这样：

return subject
    .flatMap(s -> subjectRepository.findById(s.getParentId())
        .map(parent -> {
          s.setParentId(parent.getId());
          s.setCreatedDate(LocalDateTime.now());
          s.setRoute(Utils.buildRoute(child, parent));
          return s;
        }))
    .flatMap(subjectRepository::insert);