如何解决Spring Data Mongodb反应性通量
我有下一个代码。
private Flux<Company> saveCompanies(List<Company> companies) {
return Flux.fromIterable(companies)
.flatMap(c -> companyRepository.exists(QCompany.company.name.eq(c.getName()))
.flatMap(exists ->
!exists ? companyRepository.save(c) : Mono.empty()
));
}
我应该怎么做,直到方法检查每个公司是否存在,如果不存在,请保存它。
所以我希望这种方法完成他的工作并等待完成。 为此,我这样调用此方法。
saveCompanies(companies).then().subscribe();
但它不会阻塞,直到完成。
我尝试按批量保存大小为10的公司。
但是,最终我明白了
com.mongodb.MongoWaitQueueFullException: Too many threads are already waiting for a connection.
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。