我目前正在使用Project Reader,我遇到了一个场景,我不确定是使用doOnComplete()还是使用Subscribe()的第三个参数.两者似乎都是在发布者发出完成信号时调用的,但我怀疑它们之间存在一些差异.
下面是我正在使用的代码示例:
Flux.range(1, 10)
.doOnComplete(() -> log.info("[Complete]"))
.subscribe(
data -> log.info("[data] : {}", data),
error -> log.info("[error] : {}", error.getMessage()),
() -> log.info("[Subscribe Complete]")
);
在这段代码中,doOnComplete()和订阅()的第三个参数都在流完成时记录一条消息.然而,我不确定什么时候使用一个而不是另一个.
提前感谢您的帮助!