Здравствуйте. использую rx2 для работы с firebase & room.
firebaseRef.child(itemId).rxRemoveValue()
.andThen(multiplFirebaseCallsThatReturnCompletable())
.andThen(localDbRoom.delete(data))
.subscribeOn(
schedulersFacade.io())
.observeOn(schedulersFacade.main()
... далее идет наблюдатель.
сначала делаю запросы в firebase, потом несколько несколько удалений в firebase которые возвращают completable. Все норм работает, в firebase все удаляется, ну и в параллельном потоке естестно не в основном. но под конец, когда доходит дело, до удаления соответствующих данных из room, при использовании оператора andThen - вываливает ошибка, о том, что нельзя в базу в главном потоке. почему так?