我是Rx世界的新手,所以请容忍我。
我的代码是用Kotlin编写的,但是Java代码也会有帮助。
我有两个方法,其中一个从数据库加载任务,如果有任务,我想把它们发送到服务器。
fun getListFromDb(): Single<List<TaskEntity>> {
return taskEntityDao.getAll()
}
fun syncTasks(localTasks: TaskSyncRequest): Observable<ApiResponse<List<TaskEntity>>> {
return taskServices.syncTasks(localTasks)
}
我知道我可以使用平面映射来链接可观察对象,但就是不能在单个和可观察对象之间工作。
发布于 2018-09-29 07:32:37
尝试使用flatMapObservable
,你可以使用这种方法将单变量转换为可观测值;
https://stackoverflow.com/questions/52190121
复制相似问题