transaction<T> method

  1. @override
Future<T> transaction<T>(
  1. FutureOr<T> f(
    1. Database
    )
)

Run query in a transaction.

Implementation

@override
Future<T> transaction<T>(FutureOr<T> Function(Database) f) async {
  return _pool.runTx((pgContext) async {
    var exec = PostgreSqlDatabase(pgContext, logger: logger);
    return await f(exec);
  });
}