ensureAlreadyStarted method

  1. @override
Future<Satellite> ensureAlreadyStarted(
  1. DbName dbName
)
inherited

Implementation

@override
Future<Satellite> ensureAlreadyStarted(DbName dbName) async {
  final starting = startingPromises[dbName];
  if (starting != null) {
    return starting;
  }

  final satellite = satellites[dbName];
  if (satellite != null) {
    return satellite;
  }

  throw Exception('Satellite not running for db: $dbName');
}