display the performed operation
This commit is contained in:
parent
d5ae4cabf2
commit
229285ed4d
1 changed files with 7 additions and 3 deletions
|
@ -111,14 +111,18 @@ class QueueThread internal constructor(
|
||||||
// Pickup 1st command and set performing variable
|
// Pickup 1st command and set performing variable
|
||||||
if (queue.size() > 0) {
|
if (queue.size() > 0) {
|
||||||
queue.pickup()
|
queue.pickup()
|
||||||
if (queue.performing() != null) {
|
val cont = queue.performing()?.let {
|
||||||
aapsLogger.debug(LTag.PUMPQUEUE, "performing " + queue.performing()?.status())
|
aapsLogger.debug(LTag.PUMPQUEUE, "performing " + it.status())
|
||||||
rxBus.send(EventQueueChanged())
|
rxBus.send(EventQueueChanged())
|
||||||
queue.performing()?.execute()
|
rxBus.send(EventPumpStatusChanged(it.status()))
|
||||||
|
it.execute()
|
||||||
queue.resetPerforming()
|
queue.resetPerforming()
|
||||||
rxBus.send(EventQueueChanged())
|
rxBus.send(EventQueueChanged())
|
||||||
lastCommandTime = System.currentTimeMillis()
|
lastCommandTime = System.currentTimeMillis()
|
||||||
SystemClock.sleep(100)
|
SystemClock.sleep(100)
|
||||||
|
true
|
||||||
|
} ?: false
|
||||||
|
if (cont) {
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue