Saud Khan
05/17/2024, 9:18 AMprivate var selectedVariantIdFlow = MutableStateFlow(variantId)
val dataFlow = selectedVariantIdFlow.flatMapMerge { variantId ->
store.stream(
StoreReadRequest.cached(
key = variantId,
refresh = false
)
).map {
println("MAGIC")
}
}
and then I can trigger updates based on the status of dataFlow
. What I notice in my particular set up in that even if I switch between only two variants (which are cached for 25 minutes), in the 15th the store flow is no longer triggering the transform (MAGIC). Specially since 15 seems very specific and close to 16, I have been racking my brain trying to figure out what could it be. So couple of questions:
1. Is there a way to enable additional logging in stream or something to help with debugging? I didn't see anything in the docs or the public APIs
2. Any idea on how to approach on debugging this issue?\Saud Khan
05/17/2024, 1:25 PMSaud Khan
05/17/2024, 4:13 PMMatthew Ramotar
05/23/2024, 1:46 PM