Компоненты архитектуры Android Room ViewModel CompleteableFormAction

Поэтому я подумал, что попробую « Room на небольшом побочном проекте. Я следовал примеру Флорины Мунтенеску: компоненты андроидной архитектуры

Я уделяю особое внимание классам: UserActivity.kt , UserViewModel.kt , UserDao.kt

UserViewModel#updateUserName() возвращает Completable и должен быть подписан на возврат onComplete или onError

Когда я пытаюсь поместить свой эквивалент viewModel.updateUserName(userName) в цепочку RxBindings . Если я подпишусь на него, я передам Disposable! в onNext со значением "DISPOSED" в окончательной .subscribe

Проблема в том, что это не приведет к ошибке и, следовательно, никогда не узнает, есть ли проблема

Как я могу адаптировать код ниже, чтобы окончательная .subscribe вернула правильные события?

 RxTextView.textChanges(editText) .debounce(250L, TimeUnit.MILLISECONDS, schedulers.main) .subscribeOn(schedulers.main) .observeOn(schedulers.disk) .map({ name -> viewModel.updateUserName(name) .subscribe( { Timber.d(“Success”) }, { error -> Timber.d(error, “something went wrong”)) }) }) .observeOn(schedulers.main) .subscribe( { Timber.d("name changed $it}") }, { Timber.e(it, "name error") }) 

заранее спасибо

М.

Поверните это

 .map({ name -> viewModel.updateUserName(name) .subscribe( { Timber.d(“Success”) }, { error -> Timber.d(error, “something went wrong”)) }) }) 

К этому

 .flatMapCompletable name -> viewModel.updateUserName(name))