ReplayProcessor<Integer> processor = ReplayProcessor.cacheLast();. Flux.range(1, 5) .doOnNext(integer -> {. processor.onNext(integer);. }).
確定! 回上一頁