All rights reserved. 33 Mono.fromCallable(() -> LocalDateTime.now()) .repeat(6) .parallel(5) .runOn(Schedulers.parallel()) .subscribe( dateTime -> System.out.printf("[%s] time -> %s%n", Thread.currentThread().getName(), dateTime)); [parallel-2] time -> 2018-07-29T19:32:52.850318900 [parallel-3] time -> 2018-07-29T19:32:52.850318900 [parallel-1] time -> 2018-07-29T19:32:52.849319700 [parallel-4] time -> 2018-07-29T19:32:52.850318900 [parallel-1] time -> 2018-07-29T19:32:52.850318900 [parallel-1] time -> 2018-07-29T19:32:52.850318900