Как связать 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)
}

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

Answer 1

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