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 где ты все делаешь синхронно и возвращаешь
Обсуждают сегодня