add method

void add(
  1. MutationToken token
)

Adds a MutationToken to this state.

Implementation

void add(MutationToken token) {
  final vbId = token._partitionId;
  final vbSeqNo = token._sequenceNumber;
  final bucketName = token._bucketName;

  final tokens = _data.putIfAbsent(bucketName, () => {});
  if (!tokens.containsKey(vbId)) {
    tokens[vbId] = token;
  } else {
    final otherToken = tokens[vbId]!;
    final otherTokenSeqNo = otherToken._sequenceNumber;
    if (otherTokenSeqNo < vbSeqNo) {
      tokens[vbId] = token;
    }
  }
}