假设我们正在使用
.create()
从 SharedPrefs
中获取一个通用的 Object
:return Observable.create(subscriber -> {
String json = sharedPreferences.getString(key, "");
T myClass = gson.fromJson(json, generic);
subscriber.onNext(myClass);
subscriber.onComplete();
});
使用 .fromCallable()
:
return Observable.fromCallable(() -> {
String json = sharedPreferences.getString(key, "");
return gson.fromJson(json, generic);
});
如果我们在从Observable.create()
第一次发射后立即调用onComplete()
和使用Observable.fromCallable()
有什么区别?如果有,有哪些优缺点
?