RadioRepository.java

RadioRepository.java

public class RadioRepository {
    //...
    public Flowable<Resource<List<GenreEntity>>> getGenres() {
        return Flowable.create(emitter -> new NetworkBoundSource<List<GenreEntity>, List<Genre>>(emitter) {

            @Override
            public Single<List<Genre>> getRemote() {
                return firebaseService.getGenres();
            }

            @Override
            public Flowable<List<GenreEntity>> getLocal() {
                return genresDao.getAll();
            }

            @Override
            public void saveCallResult(List<GenreEntity> data) {
                genresDao.insert(data);
            }

            @Override
            public Function<List<Genre>, List<GenreEntity>> mapper() {
                return EntityMapper.convert();
            }
        }, BackpressureStrategy.BUFFER);
    }
}