diff --git a/omnipod-dash/src/main/java/info/nightscout/androidaps/plugins/pump/omnipod/dash/OmnipodDashPumpPlugin.kt b/omnipod-dash/src/main/java/info/nightscout/androidaps/plugins/pump/omnipod/dash/OmnipodDashPumpPlugin.kt index 4856f351b9..8ab1e04845 100644 --- a/omnipod-dash/src/main/java/info/nightscout/androidaps/plugins/pump/omnipod/dash/OmnipodDashPumpPlugin.kt +++ b/omnipod-dash/src/main/java/info/nightscout/androidaps/plugins/pump/omnipod/dash/OmnipodDashPumpPlugin.kt @@ -9,6 +9,7 @@ import info.nightscout.androidaps.data.DetailedBolusInfo import info.nightscout.androidaps.data.PumpEnactResult import info.nightscout.androidaps.events.EventPreferenceChange import info.nightscout.androidaps.events.EventProfileSwitchChanged +import info.nightscout.androidaps.events.EventRefreshOverview import info.nightscout.androidaps.events.EventTempBasalChange import info.nightscout.androidaps.interfaces.* import info.nightscout.androidaps.logging.AAPSLogger @@ -231,9 +232,9 @@ class OmnipodDashPumpPlugin @Inject constructor( name = "ConnectionThread", ) { try { - stopConnecting?.let{ + stopConnecting?.let { val error = omnipodManager.connect(it).ignoreElements().blockingGet() - aapsLogger.info(LTag.PUMPCOMM, "connect error=${error}") + aapsLogger.info(LTag.PUMPCOMM, "connect error=$error") } } finally { synchronized(this) { @@ -1203,11 +1204,17 @@ class OmnipodDashPumpPlugin @Inject constructor( .map { handleCommandConfirmation(it) } .ignoreElement(), checkPodKaput(), + refreshOverview(), post, ) ) } + private fun refreshOverview(): Completable = Completable.defer { + rxBus.send(EventRefreshOverview("Dash command", false)) + Completable.complete() + } + private fun handleCommandConfirmation(confirmation: CommandConfirmed) { val command = confirmation.command val historyEntry = history.getById(command.historyId)