两种方法的适当反应算子

Question

我有两种相互依赖的方法。

Flux<DataBuffer> flux = service1.get();
Mono<String> s = service2.store(flux);

service1。get（）返回Flux

service2.store通量

Service2是被动的外部客户端，它将数据存储到文件并返回引用。

我需要使service2调用依赖于service1，但我想保留参数流量，并只调用每个方法一次。目的是调用service2。存储以防万一服务成功响应1。获取。

例如。

public Mono<String> mainMethod() {
    return service1.get()
      .unknownOperator(flux -> service2.store(flux))
      .doOnError(e -> log.error(e.getMessage));
}

你能告诉我正确的操作员而不是未知的操作员吗。

错误的处理方式如下：

1. service1中出现错误。get应该被记录并从mainMethod返回<代码>服务2。无法调用存储
2. service2中出现错误。应记录存储，并从mainMethod返回

Answer 1

在service2.store?中使用Flux作为参数是不是也很奇怪？我猜你只是想执行service1.get（）. CollectList（），所以你有一个service1结果的Mono。之后你可以做一个平面地图？例如。

service1.get()
    .collectList()
    .flatmap(service2::store) // .flatmap(list -> service2.store(list)
    .doOnError(e -> log.error(e.getMessage))