watchAll<T extends Table, D> method

Implementation

@override
Stream<List<D>> watchAll<T extends Table, D>() {
  try {
    final table = _getTable<T, D>();
    return _database.select(table).watch();
  } catch (e) {
    throw DatabaseBridgeException(error: e);
  }
}