diff --git a/lib/src/io_utils.dart b/lib/src/io_utils.dart index a93dab00e5..5ade007a67 100644 --- a/lib/src/io_utils.dart +++ b/lib/src/io_utils.dart @@ -117,12 +117,11 @@ final RegExp partOfRegexp = RegExp('part of '); 'as Dartdoc 1.0.0') final RegExp newLinePartOfRegexp = RegExp('\npart of '); -/// Best used with Future. -class MultiFutureTracker { +class MultiFutureTracker { /// Approximate maximum number of simultaneous active Futures. final int parallel; - final Set> _trackedFutures = {}; + final Set> _trackedFutures = {}; MultiFutureTracker(this.parallel); @@ -139,9 +138,9 @@ class MultiFutureTracker { /// /// If the closure does not handle its own exceptions, other calls to /// [addFutureFromClosure] or [wait] may trigger an exception. - Future addFutureFromClosure(Future Function() closure) async { + Future addFutureFromClosure(Future Function() closure) async { await _waitUntil(parallel - 1); - Future future = closure(); + var future = closure(); _trackedFutures.add(future); // ignore: unawaited_futures future.then((f) { diff --git a/lib/src/tool_runner.dart b/lib/src/tool_runner.dart index 23e8737fc8..e29e7a173d 100644 --- a/lib/src/tool_runner.dart +++ b/lib/src/tool_runner.dart @@ -19,7 +19,7 @@ typedef FakeResultCallback = String Function(String tool, /// Set a ceiling on how many tool instances can be in progress at once, /// limiting both parallelization and the number of open temporary files. -final MultiFutureTracker _toolTracker = MultiFutureTracker(4); +final MultiFutureTracker _toolTracker = MultiFutureTracker(4); class ToolTempFileTracker { final ResourceProvider resourceProvider;