SpringWebFlux使用笔记

记录使用SpringWebFlux的一些笔记。

groupBy

对flux进行分组。

channelOnlineCityBoFlux.sort((s1, s2) -> Objects.requireNonNull(s1.getInitial()).compareTo(s2.getInitial()))
  .groupBy(city -> city.getInitial().substring(0, 1).toUpperCase())
  .sort((s1, s2) -> Objects.requireNonNull(s1.key()).compareTo(s2.key()))
  .flatMap(gf -> gf.collectList()
          .map(cityList -> {
              ChannelOnlineCityGroupByPinYinBo cityGroupByPinYinBo = new ChannelOnlineCityGroupByPinYinBo();
              cityGroupByPinYinBo.setLetter(gf.key());
              cityGroupByPinYinBo.setCities(cityList);
              return cityGroupByPinYinBo;
          }));

handle

handle作用相当于是filter和map的组合。