Reactor对通量的操作会按顺序进行吗？

Question

如果我在通量上有两个平面图，它们是否总是按顺序执行

Flux.just(1,2,3,4)
    .flatMap(...) 
    .flatMap(...) // Will this always execute 2nd?

Answer 1

让我们来看这些小例子：

Flux.just(3, 2, 1)
  .flatMap(e -> {
    System.out.println("First FlatMap : " + e);
    return Mono.just(e).delayElement(Duration.ofMillis(e * 100));
  })
  .flatMap(e -> {
    System.out.println("Second FlatMap : " + e);
    return Mono.just(e);
  })
  .blockLast();

/*
First FlatMap : 3
First FlatMap : 2
First FlatMap : 1
Second FlatMap : 1
Second FlatMap : 2
Second FlatMap : 3
*/

Flux.just(3, 2, 1)
  .flatMap(e -> {
    System.out.println("First FlatMap : " + e);
    return Mono.just(e);
  })
  .flatMap(e -> {
    System.out.println("Second FlatMap : " + e);
    return Mono.just(e);
  })
  .blockLast();

/*
First FlatMap : 3
Second FlatMap : 3
First FlatMap : 2
Second FlatMap : 2
First FlatMap : 1
Second FlatMap : 1
*/

我们可以说，操作符按照元素的出现顺序处理元素。

Answer 2

这取决于你的确切意思——细节在这里很重要。

对于任何给定的元素，答案都是肯定的——它将由第一个平面地图调用处理，然后由第二个平面地图调用处理该平面地图调用的结果。回想一下，Reactor中的运算符，类似于香草Java流，是链式的——所以没有合理的方法可以让它们按顺序运行。

但是，对于所有元素，没有-因为它不会处理所有4个元素的第一个平面图调用，然后处理所有4个元素的第二个平面图调用-每个元素都是独立处理的。当您考虑到通量类似于可能没有终点的元素流，而不是一个定义的、有界的集合时，如果它不这样做，那么它就没有多大意义。