信号上游选择不同的路径 onError - Spring Reactor
Signal Upstream to choose different path onError - Spring Reactor
我有以下代码，
ClassA {
Mono<Integer> execute(ListElement listElement) {
//returns mono on success and throwable on failure
}
}
Flux.fromIterable(list)
.flatMap( listElement -> classA.execute(listElement)
.doOnError(throwable -> Mono.just(500)).flatMap(......)
当调用 execute 失败时，是否可以用不同的方式处理来自源的元素？即不调用为其中一个元素抛出异常的相同方法？
我认为这不能完成，因为它违背了响应式清单。
"If a Publisher signals either onError or onComplete on a Subscriber,
that Subscriber’s Subscription MUST be considered cancelled."
我有以下代码，
ClassA {
Mono<Integer> execute(ListElement listElement) {
//returns mono on success and throwable on failure
}
}
Flux.fromIterable(list)
.flatMap( listElement -> classA.execute(listElement)
.doOnError(throwable -> Mono.just(500)).flatMap(......)
当调用 execute 失败时，是否可以用不同的方式处理来自源的元素？即不调用为其中一个元素抛出异常的相同方法？
我认为这不能完成，因为它违背了响应式清单。
"If a Publisher signals either onError or onComplete on a Subscriber, that Subscriber’s Subscription MUST be considered cancelled."