diff options
Diffstat (limited to 'opendc-common/src/main/kotlin/org/opendc/common/util')
| -rw-r--r-- | opendc-common/src/main/kotlin/org/opendc/common/util/Pacer.kt | 4 | ||||
| -rw-r--r-- | opendc-common/src/main/kotlin/org/opendc/common/util/TimerScheduler.kt | 4 |
2 files changed, 4 insertions, 4 deletions
diff --git a/opendc-common/src/main/kotlin/org/opendc/common/util/Pacer.kt b/opendc-common/src/main/kotlin/org/opendc/common/util/Pacer.kt index edf607d2..b6141db1 100644 --- a/opendc-common/src/main/kotlin/org/opendc/common/util/Pacer.kt +++ b/opendc-common/src/main/kotlin/org/opendc/common/util/Pacer.kt @@ -26,7 +26,7 @@ import kotlinx.coroutines.Delay import kotlinx.coroutines.DisposableHandle import kotlinx.coroutines.InternalCoroutinesApi import java.lang.Runnable -import java.time.Clock +import java.time.InstantSource import kotlin.coroutines.ContinuationInterceptor import kotlin.coroutines.CoroutineContext @@ -40,7 +40,7 @@ import kotlin.coroutines.CoroutineContext */ public class Pacer( private val context: CoroutineContext, - private val clock: Clock, + private val clock: InstantSource, private val quantum: Long, private val process: (Long) -> Unit ) { diff --git a/opendc-common/src/main/kotlin/org/opendc/common/util/TimerScheduler.kt b/opendc-common/src/main/kotlin/org/opendc/common/util/TimerScheduler.kt index 44d6010f..864512d3 100644 --- a/opendc-common/src/main/kotlin/org/opendc/common/util/TimerScheduler.kt +++ b/opendc-common/src/main/kotlin/org/opendc/common/util/TimerScheduler.kt @@ -25,7 +25,7 @@ package org.opendc.common.util import kotlinx.coroutines.Delay import kotlinx.coroutines.DisposableHandle import kotlinx.coroutines.InternalCoroutinesApi -import java.time.Clock +import java.time.InstantSource import java.util.ArrayDeque import java.util.PriorityQueue import kotlin.coroutines.ContinuationInterceptor @@ -37,7 +37,7 @@ import kotlin.coroutines.CoroutineContext * @param context The [CoroutineContext] to run the tasks with. * @param clock The clock to keep track of the time. */ -public class TimerScheduler<T>(private val context: CoroutineContext, private val clock: Clock) { +public class TimerScheduler<T>(private val context: CoroutineContext, private val clock: InstantSource) { /** * The [Delay] instance that provides scheduled execution of [Runnable]s. */ |
