0

我是 Rx 世界的新手，所以请多多包涵。

我的代码在 Kotlin 中，但 Java 代码也会有所帮助。

我有两种方法，其中一种从数据库加载任务，如果有任务，我想将它们发送到服务器。

fun getListFromDb(): Single<List<TaskEntity>> {
    return taskEntityDao.getAll()
}

 fun syncTasks(localTasks: TaskSyncRequest): Observable<ApiResponse<List<TaskEntity>>> {
    return taskServices.syncTasks(localTasks)
}

我知道我可以使用 flatmap 来链接 observables，但无法让它在 Single 和 Observables 之间工作。

4

1 回答 1

2

尝试使用flatMapObservable 您可以使用此方法将单个转换为可观察；

于 2018-09-28T23:32:37.353 回答