如何从反应堆中捕获例外？

Question

我想从通量中捕获异常，我的代码是这样的：

        try {
            Flux.just("key1", "key2", "key3")
                    .doOnNext(System.out::println)
                    .map(k -> {
                        if (!k.equals("key1")) {
                            throw new RuntimeException("Not key1"); // 1
                        }
                        return "External Value, key:" + k;
                    })
                    .subscribe(System.out::println); // 2
        } catch (Throwable e) {
            System.out.println("Got exception"); // 3
        }

输出是：

key1
External Value, key:key1
key2
[ERROR] (main) Operator called default onErrorDropped - reactor.core.Exceptions$ErrorCallbackNotImplemented: java.lang.RuntimeException: Not key1
reactor.core.Exceptions$ErrorCallbackNotImplemented: java.lang.RuntimeException: Not key1
Caused by: java.lang.RuntimeException: Not key1
    at com.cxd.study.reactor.HandlingErrors.lambda$catchException$7(HandlingErrors.java:153)
...

看来我的 catch 在步骤3中从未达到。

我知道我可以在这样的步骤2上找到例外：.subscribe（System.out :: println，e-＆gt; system.out.println（“ get exception'exception'））。

但是，我该如何从步骤1中抓住例外呢？

Answer 1

您可以使用onerror（）操作员处理错误案例，或者如果您想记录异常，则可以使用doonError（）操作员。