return Observable.defer{
val id = taskCacheDao.addTask(task)
Observable.just(taskCacheDao.getTask(id))
}
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
}
Вот метод репозитория который возвращает id созданной записи.
Если написать код уровня
myRepo.addTask(task)
то функция переданная в defer() не выполнится. Или я не прав?
тебе надо single возвращать а метод будет fromCallable где ты все делаешь синхронно и возвращаешь
Обсуждают сегодня