Replace vars with finals

example/example.dart

@@ -18,13 +18,13 @@ class Program {
     await Future.wait([runFuture(1), runFuture(2), runFuture(3), runFuture(4)]);
 
     // Read and print file content to stdout
-    var content = await file.readAsString();
+    final content = await file.readAsString();
     print(content);
   }
 }
 
 void main() async {
-  var program = Program();
+  final program = Program();
 
   // Write header to example file
   await program.file.writeAsString("EXAMPLE FILE\n");

lib/src/event.dart

@@ -28,7 +28,7 @@ class Event {
     if (_flag) return;
     _flag = true;
 
-    for (var waiter in _waiters) {
+    for (final waiter in _waiters) {
       if (!waiter.isCompleted) waiter.complete();
     }
 
@@ -43,7 +43,7 @@ class Event {
   Future<void> wait() async {
     if (_flag) return;
 
-    var waiter = _FutureWaiter();
+    final waiter = _FutureWaiter();
     _waiters.add(waiter);
 
     return waiter.future;
@@ -52,7 +52,7 @@ class Event {
   /// Cancel all futures waiting for this [Event] to be set (those that are waiting for [wait]
   /// to return). This function throws an [EventCancelledException] to all these futures.
   void cancelAll() {
-    for (var waiter in _waiters) {
+    for (final waiter in _waiters) {
       waiter.completeError(EventCancelledException());
     }
 

lib/src/lock.dart

@@ -51,7 +51,7 @@ class Lock extends _Acquirable {
       return;
     }
 
-    var waiter = _FutureWaiter();
+    final waiter = _FutureWaiter();
     _waiters.add(waiter);
 
     return waiter.future;
@@ -64,7 +64,7 @@ class Lock extends _Acquirable {
       if (_waiters.isEmpty) {
         _locked = false;
       } else {
-        var waiter = _getNextWaiter();
+        final waiter = _getNextWaiter();
         waiter.complete();
       }
     }
@@ -84,7 +84,7 @@ class Lock extends _Acquirable {
   /// [LockAcquireFailureException] to them.
   void cancelAll() {
     while (_waiters.isNotEmpty) {
-      var waiter = _waiters.removeFirst();
+      final waiter = _waiters.removeFirst();
       waiter.completeError(LockAcquireFailureException());
     }
   }

lib/src/semaphore.dart

@@ -26,7 +26,7 @@ abstract class _Semaphore extends _Acquirable {
       return;
     }
 
-    var waiter = _FutureWaiter();
+    final waiter = _FutureWaiter();
     _waiters.add(waiter);
 
     return waiter.future;
@@ -38,7 +38,7 @@ abstract class _Semaphore extends _Acquirable {
     if (_waiters.isEmpty) {
       _value++;
     } else {
-      var waiter = _getNextWaiter();
+      final waiter = _getNextWaiter();
       waiter.complete();
     }
   }
@@ -57,7 +57,7 @@ abstract class _Semaphore extends _Acquirable {
   /// [SemaphoreAcquireFailureException] to them.
   void cancelAll() {
     while (_waiters.isNotEmpty) {
-      var waiter = _waiters.removeFirst();
+      final waiter = _waiters.removeFirst();
       waiter.completeError(SemaphoreAcquireFailureException());
     }
   }

lib/src/types.dart

@@ -9,7 +9,7 @@ abstract class _Acquirable {
   Future<T> run<T>(Future<T> Function() func) async {
     await acquire();
     try {
-      var result = await func();
+      final result = await func();
       return result;
     } finally {
       release();

test/event_test.dart

@@ -22,15 +22,15 @@ Future<void> mainFuture() async {
 
 void main() {
   test(
-    "Testing control flow: $event",
+    "Control flow test: $event",
     () async {
-      var futures = <Future<void>>[];
+      final futures = <Future<void>>[];
       for (int i = 0; i < futures_count; i++) {
         futures.add(sampleFuture());
       }
       futures.add(mainFuture());
 
-      var timer = Stopwatch();
+      final timer = Stopwatch();
       timer.start();
       await Future.wait(futures);
       timer.stop();
@@ -42,11 +42,11 @@ void main() {
   );
 
   test(
-    "Test event waiting cancellation: $event",
+    "Event waiting cancellation test: $event",
     () async {
       event.clear();
 
-      var futures = <Future<void>>[];
+      final futures = <Future<void>>[];
       for (int i = 0; i < futures_count; i++) {
         futures.add(sampleFuture());
       }

test/lock_test.dart

@@ -11,15 +11,15 @@ void main() {
   final lock = Lock();
 
   test(
-    "Testing control flow: $lock",
+    "Control flow test: $lock",
     () async {
-      var futures = <Future<void>>[];
+      final futures = <Future<void>>[];
       for (int i = 0; i < futures_count; i++) {
         futures.add(lock.run(() => Future.delayed(waiting)));
       }
       futures.add(Future.delayed(short_waiting));
 
-      var timer = Stopwatch();
+      final timer = Stopwatch();
       timer.start();
       await Future.wait(futures);
       timer.stop();
@@ -31,9 +31,9 @@ void main() {
   );
 
   test(
-    "Test lock acquire cancellation: $lock",
+    "Lock acquisition cancellation test: $lock",
     () async {
-      var futures = <Future<void>>[];
+      final futures = <Future<void>>[];
       for (int i = 0; i < futures_count; i++) {
         futures.add(lock.run(() => Future.delayed(waiting)));
       }

test/semaphore_test.dart

@@ -10,16 +10,16 @@ const concurrency = 4;
 
 void main() {
   final semaphores = [Semaphore(concurrency), BoundedSemaphore(concurrency)];
-  for (var semaphore in semaphores) {
+  for (final semaphore in semaphores) {
     test(
-      "Testing control flow: $semaphore",
+      "Control flow test: $semaphore",
       () async {
-        var futures = <Future<void>>[];
+        final futures = <Future<void>>[];
         for (int i = 0; i < futures_count; i++) {
           futures.add(semaphore.run(() => Future.delayed(waiting)));
         }
 
-        var timer = Stopwatch();
+        final timer = Stopwatch();
         timer.start();
         await Future.wait(futures);
         timer.stop();
@@ -31,9 +31,9 @@ void main() {
     );
 
     test(
-      "Test semaphore acquire cancellation: $semaphore",
+      "Semaphore acquire cancellation test: $semaphore",
       () async {
-        var futures = <Future<void>>[];
+        final futures = <Future<void>>[];
         for (int i = 0; i < futures_count; i++) {
           futures.add(semaphore.run(() => Future.delayed(waiting)));
         }
@@ -50,7 +50,7 @@ void main() {
   }
 
   test(
-    "BoundedSemaphore release limit",
+    "BoundedSemaphore release limit test",
     () async {
       final boundedSemaphore = BoundedSemaphore(concurrency);
       expect(boundedSemaphore.release, throwsA(isA<BoundedSemaphoreLimitException>()));