Consumer errorConsumer

我们在查看 Spring Cloud 源码的时候，会发现已经引入了 Mono 或者 Flux 相关的代码，如果对这些代码不熟悉，就会觉得有些 Spring Cloud 源码将会变得晦涩难懂。Mono 和 Flux 为 ProjectReactor 响应式框架中的核心类。其相关概念可以参考 Flux、Mono、Reactor 实战（史上最全）和 响应式编程入门之 Project Reactor。我在参考了这些文章后，查看了相应的源码，这里是将自己的理解记录下来，希望可以帮助到初学者理解 ProjectReactor 。本文的目标是可以让大家理解以下者行代码的实现逻辑。 Mono.just("hello").map(e->e+" world").map(e->e+"!").subscribe(System.out::println); 本文使用的是 java 8 ,项目中需要引入以下依赖 <dependency> <groupId>io.projectreactor</groupId> <artifactId>reactor-core</artifactId>...