summaryrefslogtreecommitdiff
path: root/opendc-common/src/main/kotlin/org/opendc/common
diff options
context:
space:
mode:
Diffstat (limited to 'opendc-common/src/main/kotlin/org/opendc/common')
-rw-r--r--opendc-common/src/main/kotlin/org/opendc/common/util/Pacer.kt4
-rw-r--r--opendc-common/src/main/kotlin/org/opendc/common/util/TimerScheduler.kt4
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.
*/