java - 反应式弹性搜索存储库不保存从通量流传递的项目

Question

我正在尝试在我的反应式存储库中保留一些数据。

public class ArticleRepositoryMultiIndexImpl implements ArticleRepositoryMultiIndex<Article> {
  private final ReactiveElasticsearchOperations operations;

  @Override
  public Flux<Article> saveAll1(Iterable<Article> entities) {
    var indexOps = operations.indexOps(indexName());
    indexOps.createSettings(Article.class);
    return operations.saveAll(entities, indexName());
  }
}

用法：

// b is a Flux<Article>, and is not empty 
articleReactiveRepository.saveAll1(b.toIterable());

告诉我我做错了什么？

标签： javareactive-programmingspring-webfluxfluxspring-data-elasticsearch