Я новичок в мире Rx, поэтому, пожалуйста, потерпите меня.
Мой код на Kotlin, но код Java также поможет.
У меня есть 2 метода, один из них загружает задачи из базы, если есть задачи, я хочу отправить их на сервер.
fun getListFromDb(): Single<List<TaskEntity>> {
return taskEntityDao.getAll()
}
fun syncTasks(localTasks: TaskSyncRequest): Observable<ApiResponse<List<TaskEntity>>> {
return taskServices.syncTasks(localTasks)
}
Я знаю, что могу использовать плоскую карту для цепочки наблюдаемых, но просто не смог заставить ее работать между Single и Observables.
Single
обозначает один элемент,Observable
- последовательность элементов. Похоже, ваш API должен возвращать сингл. В любом случае вы можете легко преобразовать наблюдаемое в одиночное, например, с помощью методаsingleOrError()
- person zella   schedule 05.09.2018