如何在Reactorwebflux中浓缩一个物体？

Question

我有接口

    public interface Enricher {
       Mono<MyObject> enrich(MyObject obj);
    }

我有这个接口的实现，它返回更新后的MyObject。

我有另一个名为CompositeEnricher的实现，它接受构造函数中的Enricher列表并执行扩展。

在非反应性的世界里，我会写这样的东西

/*
  Please note that following code is applicable only if Enricher interface returns MyObject instead of Mono<MyObject>
*/

public class CompositeEnricher implements Enricher {

  private final List<Enricher> enrichers;

  public CompositeEnricher(List<Enricher> enrichers) {
    this.enrichers = enrichers;
  }

  @Override
  public MyObject enrich(MyObject myObject) {
    MyObject updated = myObject;
    for(Enricher enricher : enrichers) {
      updated = enricher.enrich(updated);
    }
    return updated;
  }
}

如何将其更改为反应式，以便Enricher的每个实现返回Mono，包括实现Enricher接口的CompositeEnricher？

Answer 1

我用Mono解决了这个问题。展开方法。但我必须使用enrichers。迭代器（）。我想知道我是否可以在反应链中加入enrichers，而不是使用迭代器。

@Override
    public Mono<User> enrich(User user) {
        Iterator<Enricher> iterator = enrichers.iterator();
        Function<User, Publisher<User>> enrichmentFunction = u -> iterator.hasNext() ? iterator.next().enrich(u) : Mono.empty();
        return Mono.just(user)
                .expand(enrichmentFunction)
                .last();
    }

Answer 2

实际上这里根本不需要单独的CompositeEnrich类-给定一个List

Enricher composite = enrichers.stream()
        .reduce((e1, e2) -> myObj -> e1.enrich(myObj).flatMap(myObj2 -> e2.enrich(myObj2)))
        .get();

当然，如果需要的话，您可以将其充实到一个类中，但您也可以将其作为助手方法实现。