Mono / Flux 可以重复使用/它们是不可变的+无状态的吗?
Can Mono's / Flux's be re-used / are they immutable + stateless?
根据我的理解,Mono 和 Flux 是响应式编程中的 "immutable"。
这是否意味着如果我有 2 个与 运行 相同的操作(例如相同的 Mono 定义),是否可以仅重用相同的定义。
在某种程度上将这 2 个对象(Mono 和 Flux)视为指令集而不是 和 当前状态的指令。
例如:
Mono<String> someMono = // Some Custom Mono
//Perform 2 concurrent someMono calls , and block on result
Mono.zip(someMono, someMono, (a,b) -> a + b).block();
这是有效的/最佳实践的响应式代码吗?
每个项目反应堆信息:
Project Reactor streams are also reusable, which is a significant
difference from Java 8 Streams.
https://stackify.com/reactive-spring-5/
..所以答案是肯定的,它们应该是可重用的,而不是像 Java Stream、Future 等
根据我的理解,Mono 和 Flux 是响应式编程中的 "immutable"。
这是否意味着如果我有 2 个与 运行 相同的操作(例如相同的 Mono 定义),是否可以仅重用相同的定义。
在某种程度上将这 2 个对象(Mono 和 Flux)视为指令集而不是 和 当前状态的指令。
例如:
Mono<String> someMono = // Some Custom Mono
//Perform 2 concurrent someMono calls , and block on result
Mono.zip(someMono, someMono, (a,b) -> a + b).block();
这是有效的/最佳实践的响应式代码吗?
每个项目反应堆信息:
Project Reactor streams are also reusable, which is a significant difference from Java 8 Streams.
https://stackify.com/reactive-spring-5/
..所以答案是肯定的,它们应该是可重用的,而不是像 Java Stream、Future 等