Как связать Observable с Синглом в RxJava?

Question

Я новичок в мире Rx, поэтому, пожалуйста, потерпите меня.

Мой код на Kotlin, но также поможет код Java.

У меня есть 2 метода, один из них загружает задачи из базы данных, если есть задачи, я хочу отправить их на сервер.

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

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

Я знаю, что могу использовать flatmap для объединения наблюдаемых, но просто не могу заставить его работать между Single и Observables.

Answer 1

Попробуй использовать flatMapObservableВы можете использовать этот метод для преобразования одного в наблюдаемый;