diff options
| author | Janito Vaqueiro Ferreira Filho <janito@mullvad.net> | 2020-05-22 14:59:16 +0000 |
|---|---|---|
| committer | Janito Vaqueiro Ferreira Filho <janito@mullvad.net> | 2020-05-25 11:51:59 +0000 |
| commit | f871fe571be40168314069326e8c53977fe93edd (patch) | |
| tree | ab4183e899b91fece2854ff6887653f4ae185df1 /android/src/main | |
| parent | 8557e5aa95f06c1d6ebea6eae7631a024a482260 (diff) | |
| download | mullvadvpn-f871fe571be40168314069326e8c53977fe93edd.tar.xz mullvadvpn-f871fe571be40168314069326e8c53977fe93edd.zip | |
Use new `EventNotifier` API in `AccountCache`
Diffstat (limited to 'android/src/main')
| -rw-r--r-- | android/src/main/kotlin/net/mullvad/mullvadvpn/service/AccountCache.kt | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/android/src/main/kotlin/net/mullvad/mullvadvpn/service/AccountCache.kt b/android/src/main/kotlin/net/mullvad/mullvadvpn/service/AccountCache.kt index b75450b438..cdd90b0d3c 100644 --- a/android/src/main/kotlin/net/mullvad/mullvadvpn/service/AccountCache.kt +++ b/android/src/main/kotlin/net/mullvad/mullvadvpn/service/AccountCache.kt @@ -13,9 +13,6 @@ class AccountCache(val daemon: MullvadDaemon, val settingsListener: SettingsList } private val jobTracker = JobTracker() - private val subscriptionId = settingsListener.accountNumberNotifier.subscribe { accountNumber -> - handleNewAccountNumber(accountNumber) - } private var accountNumber: String? = null private var accountExpiry: DateTime? = null @@ -28,6 +25,12 @@ class AccountCache(val daemon: MullvadDaemon, val settingsListener: SettingsList } } + init { + settingsListener.accountNumberNotifier.subscribe(this) { accountNumber -> + handleNewAccountNumber(accountNumber) + } + } + fun fetchAccountExpiry() { accountNumber?.let { account -> jobTracker.newBackgroundJob("fetch") { @@ -51,7 +54,7 @@ class AccountCache(val daemon: MullvadDaemon, val settingsListener: SettingsList } fun onDestroy() { - settingsListener.accountNumberNotifier.unsubscribe(subscriptionId) + settingsListener.accountNumberNotifier.unsubscribe(this) jobTracker.cancelAllJobs() } |
