android - RxJava 与 android 存储库模式

Question

我正在使用带有存储库模式的 RxJava，Room 作为数据库，Retrofit 从 api 获取数据。这是我的 Dao

@Dao
public interface SubjectDao {

    @Insert(onConflict = OnConflictStrategy.REPLACE)
    void insert(SubjectEntity... subjects);

    @Insert(onConflict = OnConflictStrategy.REPLACE)
    void insertSubjectEntities(List<SubjectEntity> subjectEntities);

    @Insert(onConflict = OnConflictStrategy.IGNORE)
    long createSubjectIfNotExists(SubjectEntity subject);

    @Query("SELECT * FROM "+ DbConstants.SUBJECT_LIST_NAME)
    Single<List<SubjectEntity>> getAllSubjects();

}

API调用:

public interface BcsQuestionService {
    @GET("get/bTQwGnFsky?indent=2")
    Observable<List<SubjectModel>> getAllSubject();
}

这是我的仓库:

public class SubjectRepo extends BaseRepo {

    private static final String TAG = "SubjectRepo";

    @Inject
    public SubjectRepo(DataManager dataManager, SubjectService apiService) {
        super(dataManager, apiService);
    }

    public Observable<List<SubjectModel>> getSubjectList() {
        return Observable
                .concatArray(getDbSubjectList(), getApiSubjectList())
                .observeOn(AndroidSchedulers.mainThread());
    }

    public Observable<List<SubjectModel>> getDbSubjectList() {
        return mDataManager.getSubjectList()
                .filter(new Predicate<List<SubjectEntity>>() {
                    @Override
                    public boolean test(List<SubjectEntity> subjectEntities) throws Exception {
                        return !ListUtils.isEmpty(subjectEntities);
                    }
                }).map(new Function<List<SubjectEntity>, List<SubjectModel>>() {
                    @Override
                    public List<SubjectModel> apply(List<SubjectEntity> subjectEntities) throws Exception {
                        List<SubjectModel> models = new ArrayList<>();
                        for (SubjectEntity entity: subjectEntities) {
                            SubjectModel model = new SubjectModel();
                            model.setId(entity.getId());
                            model.setName(entity.getName());
                        }
                        return models;
                    }
                })
                .subscribeOn(Schedulers.io())
                .toObservable();
    }

    public Observable<List<SubjectModel>> getApiSubjectList() {
        return mApiService.getAllSubject()
                .doOnNext(new Consumer<List<SubjectModel>>() {
                    @Override
                    public void accept(List<SubjectModel> subjectModels) throws Exception {
                        List<SubjectEntity> entities = new ArrayList<>();
                        for (SubjectModel model: subjectModels) {
                            SubjectEntity entity = new SubjectEntity();
                            entity.setId(model.getId());
                            entity.setName(model.getName());
                        }
                        mDataManager.insertSubjectListEntity(entities);
                    }
                });
    }
}

目前我正在使用 concatArray 运算符从数据库和 api 获取数据。但是只有当且仅当我从数据库中什么也得不到时才想调用 api。我想将数据保存到数据库中。我应该使用哪个运算符来达到我的目的？

此外， 我想在将数据插入数据库时​​更新我的​​ View 。因此，我将更改此方法

@Query("SELECT * FROM "+ DbConstants.SUBJECT_LIST_NAME)
Single<List<SubjectEntity>> getAllSubjects();

进入这个

@Query("SELECT * FROM "+ DbConstants.SUBJECT_LIST_NAME)
Flowable<List<SubjectEntity>> getAllSubjects();

Answer 1

您可以使用以下内容

public Observable<List<SubjectModel>> getSubjectList() {
    return Observable
            .concat(getDbSubjectList(), getApiSubjectList())
            .first();
}

如果您从第一个流中获取值，则不会执行第二个流。

关于那个有一篇很好的文章here