Yuri
08/15/2019, 11:10 PMprivate val keyChangesObservable: Observable<String>
init {
keyChangesObservable = io.reactivex.Observable.create(ObservableOnSubscribe<String> { emitter ->
val listener = SharedPreferences.OnSharedPreferenceChangeListener { _, key -> emitter.onNext(key) }
emitter.setCancellable { prefs.unregisterOnSharedPreferenceChangeListener(listener) }
prefs.registerOnSharedPreferenceChangeListener(listener)
}).share()
}
gildor
08/15/2019, 11:28 PMgildor
08/15/2019, 11:29 PMlouiscad
08/16/2019, 12:19 AMEugen Martynov
08/16/2019, 10:29 AM