livedata
1、问题
LiveData更新数据报错java.lang.IllegalStateException: Cannot invoke setValue on a background thread
解决方案: setValue(T) 必须在主线程中调用 , 而 postValue(T) 既可以在主线程中调用, 也可以在子线程中调用。
viewmodel
1、在使用kotlin语言创建ViewModelFactory的时候,会抛出一下异常提示 解决方案: 在kotlinOptions中添加如下内容
kotlinOptions {
jvmTarget = '1.8'
freeCompilerArgs += [
"-Xjvm-default=all",
]
}
Hilt
在老项目中,按照官方文档加入相关依赖后,出现一下异常 官方文档 编译异常 解决方案: 1、增加下面的插件依赖
apply plugin: 'kotlin-android'
2、一定要把上面的插件依赖放在之前
//hilt
apply plugin: 'kotlin-android'
apply plugin: 'kotlin-kapt'
apply plugin: 'dagger.hilt.android.plugin'
Preferences DataStore
public class PreferenceManager {
private RxDataStore<Preferences> dataStore;
private PreferenceManager() {
//配置dataStore
dataStore = new RxPreferenceDataStoreBuilder(AppGlobalUtils.getApplication(), /*name=*/ "settings").build();
}
private static class HOLDER {
private static PreferenceManager INSTANCE = new PreferenceManager();
}
public static PreferenceManager getInstance() {
return HOLDER.INSTANCE;
}
/**
* 保存int类型的数据
* @param key
* @param value
*/
public void putInt(String key, int value) {
dataStore.updateDataAsync(prefsIn -> {
MutablePreferences mutablePreferences = prefsIn.toMutablePreferences();
mutablePreferences.set(PreferencesKeys.intKey(key), value);
return Single.just(mutablePreferences);
});
}
/**
* 获取int类型的数据
* @param key
* @return
*/
public Flowable<Integer> getInt(String key) {
Preferences.Key<Integer> EXAMPLE_COUNTER = PreferencesKeys.intKey(key);
Flowable<Integer> exampleCounterFlow =
dataStore.data().map(prefs -> prefs.get(EXAMPLE_COUNTER));
return exampleCounterFlow;
}
}
问题: 当获取数据的时候,使用Flowable.subscribe(Subscriber<? super T> s)方法,在onNext(Integer integer)没有回调该方法。
PreferenceManager.getInstance().getInt(KEY)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Subscriber<Integer>() {
@Override
public void onSubscribe(Subscription s) {
}
@Override
public void onNext(Integer integer) {
Word word = new Word(String.valueOf(integer));
mWordViewModel.insert(word);
value++;
}
@Override
public void onError(Throwable t) {
}
@Override
public void onComplete() {
}
});
解决方式1(异步): 在onSubscribe(Subscription s) 回调中调用s.request(1)方法。 为什么一定要调用s.request()方法呢?结合源码注释来理解一下: No events will be sent by a Publisher until demand is signaled via this method 在通过此方法发出需求信号之前,发布者不会发送任何事件。 解决方式2(异步): 调用subscribe(Consumer<? super T> onNext)
PreferenceManager.getInstance().getInt(KEY)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<Integer>() {
@Override
public void accept(Integer integer) throws Exception {
Word word = new Word(String.valueOf(integer));
mWordViewModel.insert(word);
value++;
}
});
解决方式3(同步): 调用blockingFirst()
Integer integer = PreferenceManager.getInstance().getInt(KEY).blockingFirst();
Word word = new Word(String.valueOf(integer));
mWordViewModel.insert(word);
value++;
|