Запуск < /p>
Mono.fromRunnable(() -> log.info("Thread {}", Thread.currentThread().getName()))
.publishOn(Schedulers.boundedElastic()).subscribe();
< /code>
logs < /p>
Thread boundedElastic-
< /code>
Почему планировщик Publishon () влияет на то, что моно Fromrunnable работает, когда он должен влиять только на операции вниз по течению, как это происходит, если я запускаю < /p>
Mono.just("x")
.doOnNext(_w -> log.info("Thread before {}", Thread.currentThread().getName()))
.publishOn(Schedulers.boundedElastic())
.doOnNext(_w -> log.info("Thread after {}", Thread.currentThread().getName()))
.subscribe();
< /code>
, где я получаю < /p>
Thread before Test worker
Thread after boundedElastic-
Подробнее здесь: https://stackoverflow.com/questions/796 ... omrunnable
