响应式 Spring Data Mongo 合并操作

Question

我想使用 Spring Integration 和 Project Reactor 写入 MongoDB。我需要的命令是合并操作，所以我从以下代码片段开始：

MergeOperation mergeOperation = Aggregation.merge()
        .intoCollection("someCollection")
        .on("_id")
        .whenMatched(MergeOperation.WhenDocumentsMatch.mergeDocuments())
        .whenNotMatched(MergeOperation.WhenDocumentsDontMatch.discardDocument())
        .build();

@Bean
public IntegrationFlow dataPipeline() {
   return IntegrationFlows.from(somePublisher)
//      .handle(-----) - MergeOperation usage syntax
      .get();
}

我想知道将合并命令与 Reactive Spring Data Mongo 一起使用的推荐方法是什么，以及它是否支持反应式流并且可以使用。因为我已经看到有一个专门用于反应式聚合的类，所以我想知道缺少反应式合并操作类是否意味着不支持反应式流的合并操作。如果可能的话，我想获得一些语法方面的帮助