项目Reactor平面图顺序是连续的吗？

Question

通量上的平面图总是连续的吗？我知道在flatMap返回通量中使用then函数时不是顺序的。项目Reactor平面图

但是如果flatMap中使用的函数返回mono，它是否总是顺序的？

假设我有一个函数，它接受一个对象，只返回Mono。

fun aFunction(foo: Int): Mono<Int> {
    return (foo + 1).toMono()
}

然后呢

Flux.just(1,2,3,4)
    .flatMap{ aFunction(it) }

总是返回2,3,4,5？

Answer 1

否，flatMap不是顺序的。flatMap急切地订阅内部流。以下是其工作原理的总结：

1. 从上游接收事件
2. 从中创造出一个内在的流
3. 订阅它
4. 从上游接收下一个事件
5. 从2开始重复
6. 合并所有这些内部流中的事件

由于这些内部订阅是并行发生的，因此不能保证哪个内部流将首先发出on完整。因此，没有订购保证。

concatMap在另一方面给出了排序保证（在它从上游接收事件的确切顺序）。这是因为它只有在前一个流发出on完整后才订阅下一个流。

这是我不久前在flatMap上写的一篇文章：https://medium.com/swlh/understanding-reactors-flatmap-operator-a6a7e62d3e95

注意：输出中很可能会出现2,3,4,5。当你的通话是同步的时，就会发生这种情况。但这并不能保证，对于任何类型的订购要求，您都不应该依赖flatMap。