小编wtt*_*tek的帖子

我有这样的任务:

Observable.just(getMessagesFromDb()).
    subscribeOn(Schedulers.newThread()).
    observeOn(AndroidSchedulers.mainThread()).
    subscribe(incomingMessages -> {
    //do something
    });

getMessagesFromDb方法在哪里同步获取消息,而不在内部进行多线程处理.根据subscribeOn方法的RxAndroid文档:

在指定的Scheduler上异步订阅Observvers到此Observable

还有我的问题 - 为什么数据库请求在主线程上执行？如何异步进行？