Room + RxJava2 Flowable получение пустого списка при отсутствии данных

Когда я начал использовать Room для работы с БД, я задавался вопросом, как же более правильно сформировать подписку на изменения данных в таблице БД, чтобы если при подписке не было данных, то наш репозиторий сразу возвращал пустой список, а не ждал появления данных.

Под подпиской я имею в виду получение текущих данных, а так-же отслеживание изменений в таблице БД и при изменении данных получение их в нашей подписке.

Как вы знаете, для создания подписки возвращающей новые данные при изменении данных в таблице, нужно использовать Flowable из RxJava2.

Примерно так будет выглядеть Dao интерфейс в коде:

@Dao interface DataDao {     @Query("SELECT * FROM DataTable")     fun getData(): Flowable<List<Data>> }

Но, теперь если в нашем приложении мы попытаемся получить список Data из таблицы DataTable, а в таблице нет записей, то наша Flowable подписка будет ждать появления данных в этой таблице, а нам не нужно ждать этого, нам нужно показать пользователю экран с текстом «Нет данных».

dataDao.getData()     .subscribeOn(Schedulers.io())     .observeOn(AndroidSchedulers.mainThread())     .subscribe { data ->         //если в таблице нет записей, то наша Flowable подписка будет ждать появления данных в этой таблице     }

Для получения требуемого поведения можно сделать следующе.

Добавляем в Dao функцию получения кол-ва записей в таблице:

@Query("SELECT COUNT(*) FROM DataTable") fun getDataCount(): Flowable<Int>

Данная функция сразу при вызове вернет значение 0, если в таблице нет данных, а так-же каждый раз при изменении данных в таблице будет иметь новое значение кол-ва записей.

Напишем вот такой код в нашем репозитории для получения необходимого поведения:

class DataRepository(private val dataDao: DataDao) { fun getData(): Flowable<List<Data>> {     return dataDao.getDataCount().switchMap {                   if (it > 0)                       dataDao.getData()                   else                       Flowable.just(emptyList())               }               .subscribeOn(Schedulers.io())               .observeOn(AndroidSchedulers.mainThread())     } }

В итоге мы получаем репозиторий с функцией getData() который при отсутствии данных в таблице вернет пустой список, а при появлении данных вернет новый список с данными.

Пример использования:

dataRepository.getData()     .subscribe { data ->         //репозиторий вернет либо пустой список, либо список с данными             }

p.s. В данном случае можно еще подумать над тем, что можно у функции getData в Dao поменять тип Flowable на Maybe (чтобы внутри нашей подписки не было двух Flowable ожидающих изменения данных в таблице) либо сделать dataDao.getData().take(1), но и в приведенном коде репозитория нет ничего криминального:) ведь используется switchMap.