上海网站建设推荐,平板网站开发环境,电商建站,广州什么地方好玩的景点推荐Hooks 是一个工具类#xff0c;它提供了一些方法#xff0c;用来在 Reactor 的各个阶段添加回调函数#xff0c;进行全局性的操作。总体来说分为三类#xff1a; 本部分算是reactor中比较高级的部分#xff0c;建议在开始上手用reactor做项目前#xff0c;大概知道有这么…Hooks 是一个工具类它提供了一些方法用来在 Reactor 的各个阶段添加回调函数进行全局性的操作。总体来说分为三类 本部分算是reactor中比较高级的部分建议在开始上手用reactor做项目前大概知道有这么一个概念即可。 做了一两个项目以后再回头来看看hooks是做什么的即可 常用的Hooks类型
丢弃事件的Hooks错误处理Hooks组装Hooks
丢弃事件的Hooks
当事件被丢弃时会调用相应的回调函数。主要包括两个方法
onNextDroppedonErrorDropped
demo
Hooks.onNextDropped(System.out::println);
Flux.just(1, 2, 3).map(i - i * 2).subscribe();错误处理Hooks
当出现错误时会调用相应的回调函数。主要包括两个方法
onOperatorErroronOperatorDebug
demo
Hooks.onOperatorError((t, context) - {System.out.println(onOperatorError: t.getMessage());return t;
});
Flux.just(1, 2, 3).map(i - i * 2).map(i - 10 / (i - 4)).subscribe();组装Hooks
当组装操作符时会调用相应的回调函数。主要包括两个方法
onEachOperatoronLastOperator
demo
Hooks.onEachOperator(p - {System.out.println(onEachOperator: p);return p;
});
Flux.just(1, 2, 3).map(i - i * 2).subscribe();
