小编And*_*kiy的帖子

我有问题的答案清单。我想保存这些答案，然后（在 mongo 给他们一个 id 之后）将它们添加到他们的问题中。

现在我这样做：

public Flux<Answer> createAnswers(List<Answer> answers) {
    return answerRepository.saveAll(answers)
            .map(answer -> {
                questionRepository.findById(answer.getQuestionId())
                        .subscribe(question -> {
                            question.getAnswers().removeIf(ans -> Objects.equals(ans.getId(), answer.getId()));
                            question.getAnswers().add(answer);
                            questionRepository.save(question).block();
                        });
                return answer;
            });
}

我也尝试过..saveAll(answers).doOnNext()，doOnEach()但是这样问题不会被保存。

似乎 map 用于转换数据而不是用于对每个元素进行操作。此外，我对调用block().

有没有更好的方法来实现我的目标？