fix
This commit is contained in:
@@ -52,10 +52,8 @@ class ScheduleRepositoryImpl @Inject constructor(
|
|||||||
return@flow
|
return@flow
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
val updated: ScheduleEntity = local.observeSchedule(key).filterNotNull().first()
|
val updated: ScheduleEntity = local.observeSchedule(key).filterNotNull().first()
|
||||||
|
val refreshedFromNetwork = cached?.timestamp != updated.timestamp
|
||||||
|
emit(DataResult.Data(updated, refreshedFromNetwork))
|
||||||
emit(DataResult.Data(updated, refreshedFromNetwork = true))
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user