Как в реактивном пайплайне обратиться к блокирующему источнику данных (например, БД)?