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 (将#修改为@）