checkConcurrency method

Future<void> checkConcurrency(
  1. int expectedVersion
)
inherited

Check optimistic concurrency control with expected version Public method for explicit concurrency checking

Implementation

Future<void> checkConcurrency(int expectedVersion) async {
  final currentVersion = isInitialized ? currentState.version : 0;

  if (currentVersion != expectedVersion) {
    throw OptimisticConcurrencyException(
      aggregateId: _aggregateId,
      expectedVersion: expectedVersion,
      actualVersion: currentVersion,
    );
  }
}