android - RxJava的使用問題。
問題描述
更新敘述一下需求,其實就是簡單的
取數(shù)據(jù)的時候先判斷本地有無緩存,有緩存則從數(shù)據(jù)庫中取得,否則從網(wǎng)絡(luò)請求并且保存到本地。
因為才接觸rxjava,這樣寫目前倒是完成了功能(運(yùn)轉(zhuǎn)正常),但是這樣寫真的是合理的嗎?本地數(shù)據(jù)庫查詢 queryDP如果沒查詢到數(shù)據(jù) deepSpaceBean=null onNext(deepSpaceBean)
@Override public Observable getDP(final String date) {return Observable.create(new Observable.OnSubscribe<DeepSpaceBean>() { @Override public void call(Subscriber<? super DeepSpaceBean> subscriber) {DeepSpaceBean deepSpaceBean = null;try { deepSpaceBean = queryDP(date);} catch (Exception e) { e.printStackTrace(); XIAOHUException xiaohuException = new XIAOHUException(e, XIAOHUException.DB_QUERY); subscriber.onError(xiaohuException);}subscriber.onNext(deepSpaceBean);subscriber.onCompleted(); }}); }" 然后接下來的操作符
.flatMap(new Func1<DeepSpaceBean, Observable<DeepSpaceBean>>() {@Overridepublic Observable<DeepSpaceBean> call(DeepSpaceBean deepSpaceBean) { **(關(guān)鍵1)** if (deepSpaceBean == null) {return mDPsRemoteDataSource.getDP(date).doOnNext(new Action1<DeepSpaceBean>() { @Override public void call(DeepSpaceBean deepSpaceBean) {try { mDPsLoaclDataSource.saveDP(deepSpaceBean);} catch (Exception e) { e.printStackTrace();} }}); } else { **(關(guān)鍵2)** return Observable.just(deepSpaceBean); }} });
關(guān)鍵1處,通過判斷 發(fā)射源 的queryDP的返回值是否為空來區(qū)分執(zhí)行不同的操作,1為空 執(zhí)行另一個mDPsRemoteDataSource.getDP(date)操作,retrofit的rx式返回
@Overridepublic Observable getDP(String date) { return PDORetrofit.getApiService().getAPOD(date);} @GET('/planetary/apod?api_key=' + API_KEY)Observable<DeepSpaceBean> getAPOD(@Query('date') String date);
然后通過操作符doOnNext執(zhí)行保存到本地數(shù)據(jù)庫的操作(就是執(zhí)行sql語句,返回為void,不關(guān)心結(jié)果)關(guān)鍵處2,如果本地數(shù)據(jù)庫查詢(發(fā)射源)到了數(shù)據(jù) deepSpaceBean != null,于是將它“包裝”成observable重新發(fā)射出去。
問題解答
回答1:發(fā)現(xiàn)可以使用 Concat 這個操作符來替換我那一堆迷之操作
回答2:rxJava這么優(yōu)雅的類庫給你嵌套了這么多的迷之縮也是醉了
回答3:既然能正常運(yùn)行,說明是合理的。但是代碼結(jié)構(gòu)和內(nèi)部邏輯,你這么寫一般人還真看不懂你寫的是什么!
相關(guān)文章:
1. css3 - 請教一下,css如何使左右兩邊的div高度自適應(yīng)相等2. centos - rpm更新軟件wkhtmltox報錯3. javascript - gitbook serve命令找不到fontsettings.js4. css - ios input 添加 readonly unselectable="on" 屬性,光標(biāo)依舊還在,怎么清除光標(biāo)5. java - 已知外匯牌價折算匯率6. javascript - 連續(xù)點擊觸發(fā)mouseleave事件7. javascript - 如何讓外層div隨內(nèi)層div的寬度自適應(yīng)調(diào)整寬度8. 關(guān)于phpstudy設(shè)置主從數(shù)據(jù)庫9. javascript - Expires和Cache-Control 設(shè)置過期時間一般是前端來寫還是服務(wù)器端來寫?10. java - shiro anon 不生效

網(wǎng)公網(wǎng)安備