movie_repository.dart

final LoadingStatus _upcomingMoviesLoadingStatus = LoadingStatus();

Future<Result> getUpcomingMovies(int page) {
  _upcomingMoviesLoadingStatus.isLoading = true;
  return _movieApi.getUpcoming(page).then((content) {
    if (content is ContentListResponse) {
      final result = _getMoviesWithResp(content, false);
      _upcomingMoviesLoadingStatus.isLoading = false;
      return result;
    }
    _upcomingMoviesLoadingStatus.isLoading = false;
    return ErrorResult(ErrorCause.noInternet());
  });
}

DataStream<List<ContentDetailData>> observeDetailedUpcoming() =>
    _movieDao.observeAllUpcoming()
      .asyncMap(getDetailsFromDb)
      .withLoading(_upcomingMoviesLoadingStatus);