問題描述

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

取數據的時候先判斷本地有無緩存，有緩存則從數據庫中取得，否則從網絡請求并且保存到本地。

因為才接觸rxjava，這樣寫目前倒是完成了功能（運轉正常），但是這樣寫真的是合理的嗎？本地數據庫查詢 queryDP如果沒查詢到數據 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) { **（關鍵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 { **（關鍵2）** return Observable.just(deepSpaceBean); }} });

關鍵1處，通過判斷 發射源 的queryDP的返回值是否為空來區分執行不同的操作，1為空 執行另一個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執行保存到本地數據庫的操作（就是執行sql語句，返回為void，不關心結果）關鍵處2，如果本地數據庫查詢（發射源）到了數據 deepSpaceBean != null，于是將它“包裝”成observable重新發射出去。

問題解答

發現可以使用 Concat 這個操作符來替換我那一堆迷之操作

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

既然能正常運行，說明是合理的。但是代碼結構和內部邏輯，你這么寫一般人還真看不懂你寫的是什么！