Я связываю два Completables с "andThen", однако кажется, что метод subscribe () никогда не вызывается.Он работал раньше, но недавно остановился, даже если не было внесено никаких изменений.
Это мой вызов rxJava:
mDisposable.add(mRepo.insert(new Animal(mAnimalId))
.subscribeOn(mScheduler.io())
.observeOn(mScheduler.ui())
.andThen(mBarn.insert(new Barn(mAnimalId, (int)Calendar.getInstance().getTimeInMillis(), false, 20)))
.subscribe(() -> getView().finishView(),
throwable -> Log.d(TAG, throwable.getMessage())
);
Мои вызовы вставки в репозитории возвращают Completable из комнаты DAOи просто вставляет новые данные.Когда эта функция вызывается, ничего не происходит, так как никаких обратных вызовов в подписке не вызывается.Я попытался onFinally (), который работал.
Что-то я делаю не так?