Override this method to send notifications
@override void sendTableTrigger(Iterable<String> tables) => _changedTablesSubject.add(Set.unmodifiable(tables));