Почему мое DataStorage обновляется очень часто ⇐ Android

[Anonymous]

Я новичок в Android Wear и работаю над обновлением данных об осложнениях каждые 10 секунд в проекте «Пример осложнений Android».
Я использую класс DataStorage для обновления данных, а ShortTextDataSourceService будет наблюдать за данные изменяются и обновляются. Но данные об осложнениях обновляются так быстро, что предполагается, что они будут обновляться каждые 10 секунд. Вот мой код, что я сделал не так?
Класс ShortTextDataSourceService:
private val scope = CoroutineScope(Dispatchers.Main + SupervisorJob())
private val dataStorage = DataStorage(this)

override fun onCreate() {
super.onCreate()
observeComplicationData(this)
dataStorage.startScheduledUpdates()
}

private fun observeComplicationData(context: Context) {
scope.launch {
dataStorage.observeComplicationState().collect { newState ->
Log.d("ShortTextDataSourceService", "Data updated: $newState")

val componentName = ComponentName(
context,
ShortTextDataSourceService::class.java
)
val requester = ComplicationDataSourceUpdateRequester.create(
context,
componentName
)
requester.requestUpdateAll()

Log.d("ShortTextDataSourceService", "Complication update requested---.")
}
}
}

override suspend fun onComplicationRequest(request: ComplicationRequest): ComplicationData? {

Log.d("ShortTextDataSourceService", "OLD VALUE :::> $updateCount")
updateCount = dataStorage.observeComplicationState().first().toString()
Log.d("ShortTextDataSourceService", "NEW VALUE :::> $updateCount")

}

Класс DataStorage:
private val COMPLICATION_STATE_KEY = longPreferencesKey("complication_state")

class DataStorage(private val context: Context) {

private val scope = CoroutineScope(Dispatchers.IO + SupervisorJob())

fun startScheduledUpdates() {

Log.d("ShortTextDataSourceService", "Scheduled Updates--only once")

scope.launch {
while (true) {
updateComplicationState()
delay(30000) // 10 seconds
}
}
}

suspend fun updateComplicationState() {
var newValue = 0L
context.dataStore.edit { preferences ->
val currentValue = preferences[COMPLICATION_STATE_KEY] ?: 0L
newValue = currentValue + 1
preferences[COMPLICATION_STATE_KEY] = newValue
}
}

fun observeComplicationState(): Flow {
Log.d("DataStorage", "Observe Updates--")
return context.dataStore.data.map { preferences ->
preferences[COMPLICATION_STATE_KEY] ?: 0L
}
}
}

val Context.dataStore: DataStore by preferencesDataStore(
name = "Complications",)


Подробнее здесь: https://stackoverflow.com/questions/793 ... frequently