runInTransactionFor<T extends Object> method

Future<Result<T>> runInTransactionFor<T extends Object>(
  1. Connection conn,
  2. Future<Result<T>> action(
    1. int txnId
    ), {
  3. IsolationLevel? isolationLevel,
  4. SavepointDialect? savepointDialect,
  5. TransactionAccessMode? accessMode,
  6. Duration? lockTimeout,
})

runInTransaction overload that accepts a Connection.

Implementation

Future<Result<T>> runInTransactionFor<T extends Object>(
  Connection conn,
  Future<Result<T>> Function(int txnId) action, {
  IsolationLevel? isolationLevel,
  SavepointDialect? savepointDialect,
  TransactionAccessMode? accessMode,
  Duration? lockTimeout,
}) =>
    runInTransaction(
      conn.id,
      action,
      isolationLevel: isolationLevel,
      savepointDialect: savepointDialect,
      accessMode: accessMode,
      lockTimeout: lockTimeout,
    );