diff --git a/vertx-lang-kotlin-coroutines/src/main/java/io/vertx/kotlin/coroutines/VertxCoroutine.kt b/vertx-lang-kotlin-coroutines/src/main/java/io/vertx/kotlin/coroutines/VertxCoroutine.kt index 0a804d8a..1a30fccc 100644 --- a/vertx-lang-kotlin-coroutines/src/main/java/io/vertx/kotlin/coroutines/VertxCoroutine.kt +++ b/vertx-lang-kotlin-coroutines/src/main/java/io/vertx/kotlin/coroutines/VertxCoroutine.kt @@ -171,6 +171,10 @@ private class ContextCoroutineDispatcher(val vertxContext: ContextInternal) : Co override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation) { (delegate as Delay).scheduleResumeAfterDelay(timeMillis, continuation) } + + override fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): DisposableHandle { + return (delegate as Delay).invokeOnTimeout(timeMillis, block, context) + } } private class VertxScheduledFuture(