Yuri
08/15/2019, 11:13 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()
}
louiscad
08/16/2019, 12:17 AMPablichjenkov
08/16/2019, 2:35 AMrunCatching{ offer(event)}
picking up any exception thrown all the way down the Flow stream. Or just catching the operation of offering the event to some EventQueue. What would be the difference of using send(...)?gildor
08/16/2019, 3:01 AMPablichjenkov
08/16/2019, 3:42 AMgildor
08/16/2019, 3:45 AMPablichjenkov
08/16/2019, 3:48 AMlouiscad
08/16/2019, 6:15 AM