myanmarking
10/15/2019, 2:50 PMmainScope.launch{
onDateChanged // conflatedBroadcastChannel
.asFlow()
.distinctUntilChanged()
.collect{ ... }
onTimeChanged // conflatedBroadcastChannel
.asFlow()
.distinctUntilChanged()
.collect{ ... }
}
Jacques Smuts
10/15/2019, 3:01 PMJacques Smuts
10/15/2019, 3:02 PMmyanmarking
10/15/2019, 3:04 PMmyanmarking
10/15/2019, 3:05 PMmainScope.launch{
val someValue = withContext(<http://dispatchers.IO|dispatchers.IO>){...}
launch{
onDateChanged // conflatedBroadcastChannel
.asFlow()
.distinctUntilChanged()
.collect{ ... } // someValue used here
}
launch{
onTimeChanged // conflatedBroadcastChannel
.asFlow()
.distinctUntilChanged()
.collect{ ... } // someValue used here
}
}
Vsevolod Tolstopyatov [JB]
10/15/2019, 3:26 PMonEach
+ `launchIn`:
onTimeChanged // conflatedBroadcastChannel
.asFlow()
.distinctUntilChanged()
.onEach { /* collect body */ }
.launchIn(mainScope)
myanmarking
10/15/2019, 3:27 PM