小编Oli*_*erM的帖子

组合两个不同类型的 Flux 实例

使用 SpringBoot 2 和 Poi 类(兴趣点):

public class Poi {
public Poi(String poidId, Double price, Double latitude, Double longitude) {...}
private String poidId;
private Double latitude;
private Double longitude;
private Double price;
//And Getters and Setters
}
Run Code Online (Sandbox Code Playgroud)

我有 2 个 Poi 通量:

Flux<Poi> availablePoisFlux;
Flux<Poi> poiFlux;
Run Code Online (Sandbox Code Playgroud)

第一个元素availablePoisFlux包含 Pois:

  • 一个 poidId
  • 没有纬度信息
  • 没有经度信息
  • 价格信息

第二个元素poiFlux包含 Pois 和:

  • 一个 poidId
  • 纬度
  • 经度
  • 没有价格信息

(poidId 是 Poi 的标识符)。

我想从两个 Flux(poiFlux 和 availablePoisFlux)创建一个带有 Pois(带有 poidId、价格、经度和纬度)的新 Flux resultPoisFlux

poidId 属性是两个 …

reactive-programming project-reactor

3
推荐指数
1
解决办法
2479
查看次数