TimeoutFeature.kt

class Timeouts {
    class Config(var postRequestTimeout: Long = 5000L)

    companion object : ApplicationFeature<ApplicationCallPipeline, Config, Unit> {
        override val key: AttributeKey<Unit> = AttributeKey("Timeouts")

        override fun install(pipeline: ApplicationCallPipeline, configure: Config.() -> Unit) {
            val postTimeout = Config().apply(configure).postRequestTimeout
            if (postTimeout <= 0) return

            pipeline.intercept(ApplicationCallPipeline.Features) {
                if (call.request.httpMethod != HttpMethod.Post) return@intercept

                withTimeout(postTimeout) {
                    proceed()
                }
            }
        }
    }
}