Skip to content
Snippets Groups Projects
Commit ea62e49f authored by chris-cwa's avatar chris-cwa
Browse files

flow for aggregated result

parent d87d8b33
No related branches found
No related tags found
No related merge requests found
...@@ -2,15 +2,21 @@ package de.rki.coronawarnapp.risk ...@@ -2,15 +2,21 @@ package de.rki.coronawarnapp.risk
import com.google.android.gms.nearby.exposurenotification.ExposureWindow import com.google.android.gms.nearby.exposurenotification.ExposureWindow
import de.rki.coronawarnapp.risk.result.AggregatedRiskResult import de.rki.coronawarnapp.risk.result.AggregatedRiskResult
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.MutableStateFlow
import javax.inject.Inject import javax.inject.Inject
class ExposureResultStore @Inject constructor() { class ExposureResultStore @Inject constructor() {
private val internalResult = MutableStateFlow<AggregatedRiskResult?>(null)
val result: Flow<AggregatedRiskResult?> = internalResult
private var entities: Pair<List<ExposureWindow>, AggregatedRiskResult?> = Pair(emptyList(), null) private var entities: Pair<List<ExposureWindow>, AggregatedRiskResult?> = Pair(emptyList(), null)
var exposureWindowEntities: Pair<List<ExposureWindow>, AggregatedRiskResult?> var exposureWindowEntities: Pair<List<ExposureWindow>, AggregatedRiskResult?>
get() = entities get() = entities
set(value) { set(value) {
entities = value entities = value
internalResult.value = value.second
} }
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment