报告未使用的 Publisher
实例。
要使用运算符(返回 Mono/Flux/Flowable 的 Mono/Flux/Flowable 对象的方法)来生成新的 Publisher
实例,您必须通过 subscribe()
订阅创建的 Publisher
。
使用工厂(例如,Mono.just()
)而不订阅返回的 Publisher
,会创建一个从未使用的对象,并被视为不必要的内存分配。
例如,Mono.just(1, 2, 3).map(i -> i + 3)
不会被执行,除非您订阅了这个 Publisher
,或者除非您通过应用运算符生成新的 Publisher
并订阅它。
示例:
未使用的 Flux
实例:
Flux.just(1, 2, 3);
消费者使用的 Flux
实例:
Flux.just(1, 2, 3).subscribe(System.out::println);
2019.3 的新功能