run method

Future<Response_T?> run({
  1. Request_T? request,
})

Implementation

Future<Response_T?> run({
  Request_T? request,
}) async {
  await _lock.lock();
  try {
    final asyncRunner = await super.nextAvailableRunner;

    return asyncRunner.run<Request_T, Response_T>(
      task: task,
      request: request,
    );
  } finally {
    _lock.unlock();
  }
}