有没有人知道为什么Flux.onErrorContinue
论证为以下类型:
public final Flux<T> onErrorContinue(BiConsumer<Throwable, Object> errorConsumer) {
...
}
代替
public final Flux<T> onErrorContinue(BiConsumer<Throwable, T> errorConsumer) {
...
}
?
好吧,我想我只是明白了:
Flux<Integer> f1 = Flux.fromStream(Stream.of(1));
Flux<String> f2 = f1.map(i ->{
throw new RuntimeException("bang");
});
f2.onErrorContinue((t, o) -> {
System.out.println("o = " + o.getClass());
}).subscribe(System.out::println);
输出:
o = class java.lang.Integer
从字符串的流量来看,您无法知道导致问题的元素是一个整数,因此唯一的选择是将其视为一个对象......