链接多个发布者以改变回应

Question

我想在每个通量事件后链接一个单声道。单声道发布者将需要通量发布的每个事件的信息。响应应该是带有通量事件和单声道响应数据的通量。

挖掘之后，我在平面地图中找到了一张地图。代码如下所示：

override fun searchPets(petSearch: PetSearch): Flux<Pet> {
    return petRepository
        .searchPets(petSearch) // returns Flux<pet>
        .flatMap { pet -> 
            petService
            .getCollarForMyPet() // returns Mono<collar>
            .map { collar -> PetConverter.addCollarToPet(pet, collar) } //returns pet (now with with collar)
        }
}

我主要关心的是：

• 代码气味是在平面图中使用地图的吗
• pet可变内容是否会因多个流量事件以及单次事件而受到比赛条件的影响
• 有没有更好的方法来处理这种行为

Answer 1

这种方法非常好。

Reactive Streams规范要求onNext事件不重叠，因此不会出现竞争条件的问题。

平地图引入了并发，因此对PetService的多次调用将并行运行。这不应该是个问题，除非search chPet两次发出Pet的某个实例。

并不是说由于这种并发，在这种情况下，Flat Map可以重新排序宠物。想象一下，搜索返回petA然后返回petB，但是petService调用petA需要更长的时间。在平面图的输出中，petB将首先发出（带有其项圈设置），然后是petA。