如何使用Room和RxJava插入数据？

Question

db.activitiesDao().insertStep(step);

这将返回臭名昭着的错误:

java.lang.IllegalStateException: Cannot access database on the main thread since it may potentially lock the UI for a long period of time.

我是RxJava的新手,不想使用AsyncTask.

Answer 1

尝试这样的事情.

Observable.fromCallable(() -> db.activitiesDao().insertStep(step))
        .subscribeOn(Schedulers.io())
        .subscribe(...);

或者,如果有无效回报,你可以这样做:

Completable.fromRunnable(new Runnable(){
        db.activitiesDao().insertStep(step)
    })
    .subscribeOn(Schedulers.io())
    .subscribe(...);