Project Reactor 中的 Flux 运算符是异步执行的吗?

do operators of Flux in Project Reactor execute asynchronously?

例如,flux.map(i->{Thread.sleep(1000); return i*i;}).flatMap(i->Monn.just(i))。 map 运算符本质上是异步执行的还是我们必须更改线程以便它可以异步执行(就像我们切换到 flux.map(i->{Thread.sleep(1000); return i*i;}).subscribeOn(Schedulers.elastic()).flatMap(i->Monn.just(i)))?

这个例子:flux.map(i->i*i).flatMap(i->Monn.just(i))。地图运算符本质上是异步执行的,还是我们必须更改线程以便它可以像上一段中那样异步执行?

获得一个Flux或者一个Mono并不一定意味着它运行在一个专用的Thread中。相反,大多数运算符继续在前一个运算符执行的线程中工作。除非指定,否则最顶层的运算符(源)本身在调用 subscribe() 的线程上运行。以上就是我想知道的