从对象中检索可迭代的通量

Question

我有一个优惠券服务，它根据id给我优惠券，退货类型是Mono。此外，我还有另一项服务，可以列出一个具有返回类型Flux的组织的所有员工。

我想创建一个反应式函数来返回给定优惠券id的流量。如果employeeDestinationType为'NONE'，则返回空流量，如果'SPECIFIED'则从优惠券对象返回员工id集，否则，如果是'ALL'，则调用外部服务并从流量中返回“id”。

这是一个参考对象。

Coupon {
id,                        //Long
employeeDestinationType,   //NONE, SPECIFIED, ALL
employeeList               //Set<Long>
} 

下面是方法签名。

public Mono<Coupon> findCouponById(long id) {}

public Flux<Employee> listAllEmployees() {}

Answer 1

您可以简单地使用一个平地图来实现这一点：

  return findCouponById(id) 
      .flatMapMany(coupon -> {
        if(...) {
          return Flux.empty();
        } else if(...) {
          return Flux.fromIterable(List.of(...));
        } else {
          return externalCall();
        }
      });