因此,我从文档中了解到,并行Flux实际上是将通量元素划分为单独的rails(本质上类似于分组)。就线程而言,这将是调度程序的工作。所以让我们来考虑一下这样的情况。所有这些都将在通过runOn()方法提供的同一个调度器实例上运行。让我们考虑以下情况:
Mono<Response> = webClientCallAPi(..)()).flatMap(i -> webClientCallApi(i)).collecttoList() // or subscribe som
但实际上,它从来没有set之后的delete。每次打印log后,我只会看到错误,比如2 any is MonoNext。然后,在这个any需要拆分一个Mono之前,我发布了一个链步骤,所以我在标记处使用flatMap而不是map。这个问题更有可能发生在我身上,特别是当函数被深深地封装在另一个函数中,其中包含了Mono。@RequestMapping("addUserSimple3")
pu