RxJava. Почему не срабатывает данный код?

Question

[terminator-light]

Только начал изучать RxJava и пытаюсь реализовать проверку на офлайн. Когда есть сеть, должно выдавать от ретрофита, при офлайне - из БД.
Код из Repository:

public Observable<List<Category>> getCategories() {
        return App.getInstance().isConnectionAvailable()
                .filter(connection -> connection)
                .switchMap(connection -> remoteDataSource.getCategories()
                        .doOnNext(categories -> localDataSource.insertCategories(categories)))
                .switchIfEmpty(observer -> localDataSource.getCategories());
    }

при сети работает корректно, а без сети из БД не выдает почему-то. Но при этом метод localDataSource.getCategories() вызывается.
Когда оставляю return localDataSource.getCategories() вместо тела вышеприведенного метода, данные из БД приходят и отображаются.
И вызов в презентере:

disposable.add(repository.getCategories()
                .compose(RxUtils.async()) // subscribeOn.io/observeOn
                .subscribe(view::showCategories, t -> ErrorHandler.handleError(view, t)));

При первом варианте в view::showCategories и ErrorHandler.handleError ничего не попадает, не вызываются.
В чем может быть дело?

Answer 1

[terminator-light]

Переделал архитектуру: чекаю сеть при получении данных из remoteDataSource. Если сети нет, кидаю ошибку. В основном репозитории делаю onErrorResumeNext, проверяю на IOException и возвращаю данные из localDataSource

Answer 2

[Денис Загаевский]

Вангую, что isConnectionAvailable() возвращает бесконечный Observable, поэтому switchIfEmpty не сработает.

Comments

[terminator-light]

поставил в тело switchIfEmpty лог

Timber.d("observer");
Timber.d(observer.toString());

срабатывает.

public boolean isInternetAvailable(){
        ConnectivityManager connectivityManager = (ConnectivityManager) 
           getSystemService(Context.CONNECTIVITY_SERVICE);

        NetworkInfo activeNetworkInfo = connectivityManager.getActiveNetworkInfo();
        return activeNetworkInfo != null && activeNetworkInfo.isConnected();
    }

    public Observable<Boolean> isConnectionAvailable(){
        Timber.d(isInternetAvailable()+" available");
        return Observable.just(isInternetAvailable());
    }

Может, с room что-то не так? данный метод вызывается, но данные не отдает
LocalDataSource

public Observable<List<Category>> getCategories() {
        Timber.d("local repository");
        return database.categoryDao().getAll();
    }

CategoryDao

@Dao
public interface CategoryDao {

    @Query("SELECT * FROM Category")
    Observable<List<Category>> getAll();

[terminator-light]

данные тоже есть

public Observable<List<Category>> getCategories() {
        Timber.d("local repository");

        Observable<List<Category>> all = database.categoryDao().getAll();
        all.isEmpty().subscribe((aBoolean, throwable) -> Timber.d(aBoolean+"")); //D/LocalDataSource: false
        return all;
    }

[Денис Загаевский]

terminator-light, хз тогда, дебажить надо. Так непонятно.

[terminator-light]

Денис Загаевский, похоже, switchIfEmpty не для этого предназначен. Он выполняет код, но не возвращает ничего, как void