Improve HotDataFlow behavior (EXPOSUREAPP-3777) (#1612)
* Fix HotDataFlow behavior. * Prevent re-execution of past submissions when the observable goes cold. * Guard internal value updates with a mutex in case the value update is not as thread-safe as we think it is. * Fix problematic testcases.
Showing
- Corona-Warn-App/src/main/java/de/rki/coronawarnapp/util/flow/HotDataFlow.kt 20 additions, 13 deletions...c/main/java/de/rki/coronawarnapp/util/flow/HotDataFlow.kt
- Corona-Warn-App/src/test/java/de/rki/coronawarnapp/util/flow/HotDataFlowTest.kt 89 additions, 3 deletions...st/java/de/rki/coronawarnapp/util/flow/HotDataFlowTest.kt
- Corona-Warn-App/src/test/java/testhelpers/coroutines/FlowTest.kt 16 additions, 6 deletions...Warn-App/src/test/java/testhelpers/coroutines/FlowTest.kt
Loading
Please register or sign in to comment