repository.dart

class Repository {

  final ApiClient _myApiClient;
  final ToDoDao _dao;

  Repository(this._remoteDataSource, this._localDataSource);

  @override
  Stream<Resource<List<ToDoItem>>> toDoItemsStream() {
    return NetworkBoundResources<List<ToDoItem>,List<ToDoItem>>()
      .asStream(
        loadFromDb: _dao.allActiveToDoItemsStream,
        shouldFetch: (data) => data == null || data.isEmpty,
        createCall: _remoteDataSource.getToDoItemsFromApi(),
        processResponse: (request) => request.toResult(),
        saveCallResult: (result) => _dao.insertToDo(result);
  }

}