Flux<Integer> firstPublisher = Flux.range(0,4).doOnNext(i -> System.out.println(i));