Scheduler constructor

Scheduler({
  1. dynamic concurrency,
})

Implementation

Scheduler({
  concurrency,
}) {
  if (concurrency < 1) {
    throw Exception('concurrency must be greater than 0');
  }
  asyncRunners = List.generate(
    concurrency,
    (_) => AsyncRunner(),
  );
}