BugFix on bundled update dispatchers.
This commit is contained in:
@@ -35,7 +35,7 @@ class BundledUpdate(
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
scope.launch {
|
scope.launch(dispatcher) {
|
||||||
try {
|
try {
|
||||||
onUpdate()
|
onUpdate()
|
||||||
delay(delay)
|
delay(delay)
|
||||||
@@ -77,7 +77,7 @@ class BundledInsert<T>(
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
scope.launch(Dispatchers.IO) {
|
scope.launch(dispatcher) {
|
||||||
try {
|
try {
|
||||||
val mySet = mutableSetOf<T>()
|
val mySet = mutableSetOf<T>()
|
||||||
queue.drainTo(mySet)
|
queue.drainTo(mySet)
|
||||||
|
|||||||
Reference in New Issue
Block a user