Я понимаю, что при использовании операций блокировки в реактивных потоках мы должны использовать Publisher<Object>.publishOn(Schedulers.elastic).subscribe(//blocking operations go here)
Я понимаю, что это имеет смысл, когда мой издатель публикует список элементов (например, Flux), будущие элементы не должны ждать, пока текущий элемент будет заблокирован операцией блокировки. Но в случае Mono
это необходимо? Потому что в моей трубе будет течь только один предмет.
PS. Я использую контроллер реактивного потока Spring Boot 2 примерно так.
@RestController("/item")
public Mono<Response> saveItem(Mono<Item> item) {
return
item.publishOn(Schedulers.elastic()) **//Do I need this ?**
.map(blockingDB.save(item))
.map(item -> new Response(Item);
}