序 本文主要研究一下flux的map与flatMap的区别 map @Test public void testMap() throws InterruptedException { Flux.just(1, 2, 3, 4) .log() .map(i -> { try

序 本文主要研究下Flux的compose与flatMap操作 compose Flux.just("1", "2","3") .log() .compose(stringFlux -> { LOGGER.info("compose executed");