openTransaction method

  1. @override
Future<PostgreSQLConnectionTransactionWrapper> openTransaction(
  1. Transaction transaction
)
override

Implementation

@override
Future<PostgreSQLConnectionTransactionWrapper> openTransaction(
  Transaction transaction,
) => openTransactionWithPool<PostgreSQLConnectionTransactionWrapper>(
  transaction,
  (connection, onTransactionContext) =>
      connection.openTransaction((connTransaction) {
        onTransactionContext(connTransaction);

        return transaction.transactionFuture.then(
          (res) => resolveTransactionResult(res, transaction, connection),
          onError: (e, s) {
            cancelTransaction(transaction, connTransaction, e, s);
            throw e;
          },
        );
      }),
);