applyPatches method

void applyPatches(ListDiffs<V> diffs)

Implementation

void applyPatches(ListDiffs<V> diffs) {
  try {
    diffs.forEach(applyPatch);
    if (!_changes.isClosed) {
      _changes.add(diffs);
    } else {
      log.warning(
          "Not propagating $diffs because the broadcast stream has closed");
    }
  } catch (e, stack) {
    log.severe("Error updating state for $debugLabel: $e", e, stack);
    rethrow;
  }
}