如何解决RxJava - Mongodb - 在flowable中,一一执行一个发布者方法
我有一个关于 Flowable 的问题。我已经尝试使用 mongodb 库来连接 java 反应性(不是 spring-data),我需要更新 flowable 对象中的属性,这个属性是“downloadInCsv”。 我用过 io.reactivex.rxjava3 和 mongodb-driver-reactivestreams 我的解决方案是:
public Flowable<LoanEntity> updateStatus(Flowable<LoanEntity> loans) {
return loans.flatMap(loan -> {
try (MongoClient client = this.mongoConnection.getClient()) {
return Single.fromPublisher(client.getDatabase(this.databaseName)
.getCollection("LoanRequest",LoanEntity.class)
.updateOne(Filters.eq("_id",loan.getId()),new Document("$set",new Document("downloadInCsv",Boolean.TRUE))))
.map(result -> {
loan.setDownloadInCsv(true);
return loan;
})
;
} catch (Exception e) {
log.info("error" + e.getLocalizedMessage());
return Flowable.empty();
}
});
}
问题是Single.fromPublisher 或者第一个flowable 中的flatMap,因为我无法使用map 返回相同的贷款,或者我的所有代码都错了。
感谢您的回答。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。