为什么3号Reactor需要单型？

Question

null

我理解Mono是一个由0或1个元素组成的流和Flux是一个由0或N个元素组成的流之间的区别。

既然Mono和Flush都在实现org.reactiveStreams.publisher ，为什么我们需要这两种类型，为什么不对所有内容都使用Flux呢？

Answer 1

想想在非反应世界中会发生什么：我们可以决定让所有函数返回list ，即使我们知道它们只返回一个元素。示例：

public List<T> findAll()     <-- looks ok

public List<T> findFirst()   <-- seems strange?

public T findFirst()         <-- better now?

那么为什么我们不总是返回列表 呢？因为有时我们使用list 和其他简单的t更方便，所以使用这种方法的用户更容易理解会发生什么。

现在，如果我们将这些例子转换到反应世界，我们会得到：

public List<T> findAll()   -->   public Flux<T> findAll()

public T findFirst()       -->   public Mono<T> findFirst()