executeTransactionOperation<R> method

FutureOr<R> executeTransactionOperation<R>(TransactionOperation op, FutureOr<R> f(DBObjectDirectoryAdapterContext connection))

Implementation

FutureOr<R> executeTransactionOperation<R>(
  TransactionOperation op,
  FutureOr<R> Function(DBObjectDirectoryAdapterContext connection) f,
) {
  var transaction = op.transaction;

  if (isTransactionWithSingleOperation(op)) {
    return executeWithPool(
      f,
      onError: (e, s) => transaction.notifyExecutionError(
        e,
        s,
        errorResolver: resolveError,
        operation: op,
        debugInfo: () => op.toString(),
      ),
    );
  }

  if (transaction.isOpen) {
    return transaction.addExecution<R, DBObjectDirectoryAdapterContext>(
      (c) => f(c),
      errorResolver: resolveError,
      operation: op,
      debugInfo: () => op.toString(),
    );
  }

  if (!transaction.isOpening) {
    transaction.open(
      () => openTransaction(transaction),
      callCloseTransactionRequired
          ? () => closeTransaction(
              transaction,
              transaction.context as DBObjectDirectoryAdapterContext?,
            )
          : null,
    );
  }

  return transaction.onOpen<R>(() {
    return transaction.addExecution<R, DBObjectDirectoryAdapterContext>(
      (c) => f(c),
      errorResolver: resolveError,
      operation: op,
      debugInfo: () => op.toString(),
    );
  });
}