actuallyChanged method

  1. @override
void actuallyChanged(
  1. DbName dbName,
  2. List<Change> changes,
  3. ChangeOrigin origin
)
override

When Satellite detects actual data changes in the oplog for a given database, it replicates it and calls actuallyChanged with the list of changes.

Implementation

@override
void actuallyChanged(
  DbName dbName,
  List<Change> changes,
  ChangeOrigin origin,
) {
  if (!_hasDbName(dbName) || changes.isEmpty) {
    return;
  }

  final tables = Set<String>.of(
    changes.map((e) => e.qualifiedTablename.tablename),
  ).toList();

  logger.debug(
    'notifying client of database changes. Changed tables: $tables. Origin: ${origin.name}',
  );

  _emitActualChange(dbName, changes, origin);
}