两种方法的正确反应运算符

Question

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

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

service1.get() 返回 Flux<DataBuffer> 或 Flux.error 以防获取操作不成功。

service2.store(Flux<DataBuffer> flux)返回Mono<String>或Mono.error以防存储操作不成功。

Service2 是响应式 feign 客户端，它将数据存储到文件并返回引用。

我需要让 service2 调用依赖于 service1，但我想保留参数 Flux 并只调用每个方法一次。 目的是打电话给service2.store，以防service1.get成功回复。

例如

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

你能告诉我正确的运营商，而不是unknownOperator。

错误应该这样处理：

1. service1.get 中的错误应被记录并从 mainMethod 返回。无法调用service2.store。
2. 应该记录service2.store 中的错误并从mainMethod 返回。

Answer 1

在 service2.store 中将 Flux 作为参数是不是也很奇怪？我猜你只是想做service1.get().collectList()，所以你有一个服务1结果的单声道。 之后你可以做一个平面图吗？例如

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