wrapped<T> method

Future<T?> wrapped<T>(
  1. Future<T?> action(
    1. CommonDatabase
    )
)

Completes the provided action in a wrapped safe environment.

Implementation

Future<T?> wrapped<T>(Future<T?> Function(CommonDatabase) action) async {
  if (isClosed || db == null) {
    return null;
  }

  final Completer completer = Completer();
  _completers.add(completer);

  try {
    return await _caught(action(db!));
  } finally {
    completer.complete();
    _completers.remove(completer);
  }
}