Upload

upload.kt

@Controller("/")
@ExecuteOn(TaskExecutors.IO)
class UploadController {
    companion object {
        private val LOG = LoggerFactory.getLogger(UploadController::class.java)

        private val executor = Executors.newSingleThreadExecutor {
            Thread(it).apply {
                name = "processing-thread"
            }
        }
        private val scheduler = Schedulers.fromExecutorService(executor)
    }

    @Consumes(MediaType.MULTIPART_FORM_DATA)
    @Post("/upload") fun post(
        @Part("file") fileUpload: StreamingFileUpload,
        httpRequest: HttpRequest<*>
    ): Mono<HttpResponse<String>> {
        LOG.info("Entered endpoint")
        return Mono.fromDirect(fileUpload.transferTo(File("x.tmp")))          
            .handle { success, sink ->
                if (!success || !fileUpload.isComplete) {
                    LOG.info("Not success")
                    sink.error(RuntimeException("Failed to transfer file"))
                } else {
                    LOG.info("Success")
                    sink.next(HttpResponse.ok("File uploaded! :)"))
                    sink.complete()
                }
            }
    }
}