summaryrefslogtreecommitdiffhomepage
path: root/android
diff options
context:
space:
mode:
authorJanito Vaqueiro Ferreira Filho <janito@mullvad.net>2020-05-22 14:59:16 +0000
committerJanito Vaqueiro Ferreira Filho <janito@mullvad.net>2020-05-25 11:51:59 +0000
commitf871fe571be40168314069326e8c53977fe93edd (patch)
treeab4183e899b91fece2854ff6887653f4ae185df1 /android
parent8557e5aa95f06c1d6ebea6eae7631a024a482260 (diff)
downloadmullvadvpn-f871fe571be40168314069326e8c53977fe93edd.tar.xz
mullvadvpn-f871fe571be40168314069326e8c53977fe93edd.zip
Use new `EventNotifier` API in `AccountCache`
Diffstat (limited to 'android')
-rw-r--r--android/src/main/kotlin/net/mullvad/mullvadvpn/service/AccountCache.kt11
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()
}