|
|
温文尔雅的作业本 · PPG LINQ | PPG LINQ Color· 7 月前 · |
|
|
鬼畜的大象 · 南阳市公布52所学科类校外培训机构“白名单” ...· 8 月前 · |
|
|
冷冷的板凳 · 现场百分百| ...· 1 年前 · |
|
|
没有腹肌的碗 · 对市十六届人大二次会议第1017号代表建议的 ...· 1 年前 · |
|
|
儒雅的皮带 · 南京哪些城市规划对后续发展产生深远影响? - 知乎· 2 年前 · |
当上游流发出nullValue时,我们可以使用'Mono.defualtIfEmpty()‘或'Mono.switchIfEmpty()’替换空值。
但
switchIfEmpty()
对上层流值的求值非常迫切。因此,我们使用Mono.defer()来进行惰性评估。
发布于 2022-10-09 10:03:54
对于
defaultIfEmpty
,您必须在程序集上提供回退值,因此它必然是迫切的。
由于
switchIfEmpty
使用Mono作为参数,因此可以同时使用它进行热切和懒惰的评估。除了缓存的Mono或Mono.just之外,大多数Mono对象/实现都是延迟评估的。
在任何情况下,无论您选择哪种运算符,都不会急切地评估上游Mono。
仅在订阅时才对上游单点进行评估。
示例1 :验证在订阅之前不会对上游进行评估:
var upstream = Mono.fromCallable(() -> {
System.out.println("UPSTREAM EVALUATION");
return "upstream";
var defaultIfEmpty = upstream.defaultIfEmpty("default");
System.out.println("Nothing evaluated yet");
Thread.sleep(2000);
System.out.println("Still not evaluated");
defaultIfEmpty.block();
输出:
Nothing evaluated yet
Still not evaluated
UPSTREAM EVALUATION
示例2 :检查switchIfEmpty是否仅在上游评估后触发
var upstream = Mono.fromRunnable(() -> System.out.println("UPSTREAM EVALUATION"));
var switchEmpty = upstream.switchIfEmpty(Mono.fromCallable(() -> {
System.out.println("SWITCH EVALUATED");
return "switch";
System.out.println("Nothing evaluated yet");
Thread.sleep(2000);
System.out.println("Still not evaluated");
switchEmpty.block();
输出:
Nothing evaluated yet
Still not evaluated
UPSTREAM EVALUATION
SWITCH EVALUATED
如果上游发送值,则不计算 示例3 :SwitchIfEmpty:
var upstream = Mono.fromCallable(() -> {
System.out.println("UPSTREAM EVALUATION");
return "upstream";
var switchEmpty = upstream.switchIfEmpty(Mono.fromCallable(() -> {
System.out.println("SWITCH EVALUATED");
return "switch";
System.out.println("Nothing evaluated yet");
|
|
儒雅的皮带 · 南京哪些城市规划对后续发展产生深远影响? - 知乎 2 年前 |