updatesForSync method

@override Stream<Set<TableUpdate>> updatesForSync(TableUpdateQuery query)

Creates a stream that emits updates synchronously if they match query.

Implementation

@override
Stream<Set<TableUpdate>> updatesForSync(TableUpdateQuery query) {
  return _tableUpdates.stream
      .map((e) => e.where(query.matches).toSet())
      .where((e) => e.isNotEmpty);
}