Запуск Mono в фоновом режиме при возврате ответа при использовании Spring Webflux

Этот вопрос связан с Немедленно вернитесь в Spring Web Flux, но я не думаю, что это одно и то же (по крайней мере, ответ меня не устраивает).

У меня есть функция, возвращающая Mono, которая при вызове запускает длительную работу. Эта функция вызывается при вызове HTTP API Spring Webflux. Вот пример:

@PutMapping("/{jobId}")
fun startNewJob(@PathVariable("jobId") jobId: String,
                request: ServerHttpRequest): Mono<ResponseEntity<Unit>> {
    val longRunningJob : Mono<Job> = startNewJob(jobId)
    longRunningJob.map { job ->
        val jobUri = generateJobUri(request, job.id)
        ResponseEntity.created(jobURI).build<Unit>()
    }
}

Проблема с приведенным выше кодом заключается в том, что создается «201 Created» после, длительное задание завершено. Я хочу запустить longRunningJob в фоновом режиме и немедленно вернуть «201 Created».

Возможно, я мог бы сделать что-то вроде этого:

@PutMapping("/{jobId}")
fun startNewJob(@PathVariable("jobId") jobId: String,
                request: ServerHttpRequest): Mono<ResponseEntity<Unit>> {

    startNewJob(jobId)
        .subscribeOn(Schedulers.newSingle("thread"))
        .subscribe()

    val jobUri = generateJobUri(request, job.id)
    val response = ResponseEntity.created(jobURI).build<Unit>()
    Mono.just(response)
}

Но мне не кажется очень идиоматичным вызывать subscribe() вручную (например, intellij жалуется, что я вызываю subscribe() в неблокирующей области). Разве нет лучшего способа составить два «потока» без использования явного subscribe? Если да, то как мне изменить функцию startNewJob выше, чтобы добиться этого?