onDatasetChanged method

  1. @protected
void onDatasetChanged(
  1. Iterable<String> affectedTables,
  2. Hlc hlc
)

Notifies listeners and updates the canonical time.

Implementation

@protected
void onDatasetChanged(Iterable<String> affectedTables, Hlc hlc) {
  assert(hlc >= canonicalTime);

  // Bump canonical time if the new timestamp is higher
  if (hlc > canonicalTime) canonicalTime = hlc;

  _tableChangesController.add((hlc: hlc, tables: affectedTables));
}