withConnection<R> method

Future<R> withConnection<R>(
  1. Future<R> fn(
    1. PostgreSQLConnection connection
    ), {
  2. PgRetryOptions? retryOptions,
})

Executa fn com uma conexão exclusiva do pool.

Com retryOptions (ou PostgreSQLPoolSettings.retryOptions), fn é executada de novo, com outra conexão, quando falha com um erro aceito por PgRetryOptions.retryIf.

Implementation

Future<R> withConnection<R>(
    Future<R> Function(PostgreSQLConnection connection) fn,
    {PgRetryOptions? retryOptions}) {
  final options = retryOptions ?? settings.retryOptions;
  Future<R> once() => _core.use(fn);
  return options == null ? once() : options.retry(once);
}