問題描述

更新敘述一下需求，其實(shí)就是簡單的

取數(shù)據(jù)的時(shí)候先判斷本地有無緩存，有緩存則從數(shù)據(jù)庫中取得，否則從網(wǎng)絡(luò)請求并且保存到本地。

因?yàn)椴沤佑|rxjava，這樣寫目前倒是完成了功能（運(yùn)轉(zhuǎn)正常），但是這樣寫真的是合理的嗎？本地?cái)?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í)行另一個(gè)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í)行保存到本地?cái)?shù)據(jù)庫的操作（就是執(zhí)行sql語句，返回為void，不關(guān)心結(jié)果）關(guān)鍵處2，如果本地?cái)?shù)據(jù)庫查詢（發(fā)射源）到了數(shù)據(jù) deepSpaceBean != null，于是將它“包裝”成observable重新發(fā)射出去。

問題解答

發(fā)現(xiàn)可以使用 Concat 這個(gè)操作符來替換我那一堆迷之操作

rxJava這么優(yōu)雅的類庫給你嵌套了這么多的迷之縮也是醉了

既然能正常運(yùn)行，說明是合理的。但是代碼結(jié)構(gòu)和內(nèi)部邏輯，你這么寫一般人還真看不懂你寫的是什么！