watchQuery method

  1. @override
Stream<List<Map<String, Object?>>> watchQuery(
  1. Table table,
  2. Query query
)
override

Implementation

@override
Stream<List<Map<String, Object?>>> watchQuery(Table table, Query query) async* {
  yield await this.query(table, query);

  await for (final _ in _tableChangeController.stream.where((event) => event.name == table.name)) {
    yield await this.query(table, query);
  }
}