Require Dart 3.2, update and fix lints

kevmoo · kevmoo · commit 26690d31dba5 · 2024-02-13T11:50:26.000-08:00
diff --git a/.github/workflows/test-package.yml b/.github/workflows/test-package.yml
@@ -47,7 +47,7 @@ jobs:
       matrix:
         # Add macos-latest and/or windows-latest if relevant for this package.
         os: [ubuntu-latest]
-        sdk: [2.19.0, dev]
+        sdk: [3.2, dev]
     steps:
       - uses: actions/checkout@b4ffde65f46336ab88eb53be808477a3936bae11
       - uses: dart-lang/setup-dart@fedb1266e91cf51be2fdb382869461a434b920a3
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,6 +1,6 @@
 ## 2.12.0-wip
 
-- Require Dart 2.19
+- Require Dart 3.2
 
 ## 2.11.0
 
diff --git a/analysis_options.yaml b/analysis_options.yaml
@@ -1,4 +1,4 @@
-# https://dart.dev/guides/language/analysis-options
+# https://dart.dev/tools/analysis#the-analysis-options-file
 include: package:dart_flutter_team_lints/analysis_options.yaml
 
 analyzer:
@@ -7,16 +7,15 @@ analyzer:
   errors:
     only_throw_errors: ignore
     unawaited_futures: ignore
+    inference_failure_on_instance_creation: ignore
+    inference_failure_on_function_invocation: ignore
+    inference_failure_on_collection_literal: ignore
 
 linter:
   rules:
     - avoid_unused_constructor_parameters
-    - comment_references
     - literal_only_boolean_expressions
     - missing_whitespace_between_adjacent_strings
     - no_adjacent_strings_in_list
     - no_runtimeType_toString
     - package_api_docs
-    - prefer_relative_imports
-    - test_types_in_equals
-    - use_super_parameters
diff --git a/lib/src/subscription_stream.dart b/lib/src/subscription_stream.dart
@@ -73,7 +73,7 @@ class _CancelOnErrorSubscriptionWrapper<T>
   @override
   void onError(Function? handleError) {
     // Cancel when receiving an error.
-    super.onError((error, StackTrace stackTrace) {
+    super.onError((Object error, StackTrace stackTrace) {
       // Wait for the cancel to complete before sending the error event.
       super.cancel().whenComplete(() {
         if (handleError is ZoneBinaryCallback) {
diff --git a/pubspec.yaml b/pubspec.yaml
@@ -4,14 +4,14 @@ description: Utility functions and classes related to the 'dart:async' library.
 repository: https://github.com/dart-lang/async
 
 environment:
-  sdk: '>=2.19.0 <4.0.0'
+  sdk: ^3.2.0
 
 dependencies:
   collection: ^1.15.0
   meta: ^1.1.7
 
 dev_dependencies:
-  dart_flutter_team_lints: ^1.0.0
+  dart_flutter_team_lints: ^2.0.0
   fake_async: ^1.2.0
   stack_trace: ^1.10.0
   test: ^1.16.0
diff --git a/test/async_cache_test.dart b/test/async_cache_test.dart
@@ -60,7 +60,7 @@ void main() {
       Future<String> throwingCall() async => throw Exception();
       await expectLater(cache.fetch(throwingCall), throwsA(isException));
       // To let the timer invalidate the cache
-      await Future.delayed(Duration(milliseconds: 5));
+      await Future.delayed(const Duration(milliseconds: 5));
 
       Future<String> call() async => 'Completed';
       expect(await cache.fetch(call), 'Completed', reason: 'Cache invalidates');
diff --git a/test/cancelable_operation_test.dart b/test/cancelable_operation_test.dart
@@ -574,8 +574,8 @@ void main() {
       test('waits for chained cancellation', () async {
         var completer = CancelableCompleter<void>();
         var chainedOperation = completer.operation
-            .then((_) => Future.delayed(Duration(milliseconds: 1)))
-            .then((_) => Future.delayed(Duration(milliseconds: 1)));
+            .then((_) => Future.delayed(const Duration(milliseconds: 1)))
+            .then((_) => Future.delayed(const Duration(milliseconds: 1)));
 
         await completer.operation.cancel();
         expect(completer.operation.isCanceled, true);
diff --git a/test/lazy_stream_test.dart b/test/lazy_stream_test.dart
@@ -14,7 +14,7 @@ void main() {
     var callbackCalled = false;
     var stream = LazyStream(expectAsync0(() {
       callbackCalled = true;
-      return Stream.empty();
+      return const Stream.empty();
     }));
 
     await flushMicrotasks();
@@ -28,7 +28,7 @@ void main() {
     var callbackCalled = false;
     var stream = LazyStream(expectAsync0(() {
       callbackCalled = true;
-      return Stream.empty();
+      return const Stream.empty();
     }));
 
     await flushMicrotasks();
@@ -95,7 +95,7 @@ void main() {
     late LazyStream stream;
     stream = LazyStream(expectAsync0(() {
       expect(() => stream.listen(null), throwsStateError);
-      return Stream.empty();
+      return const Stream.empty();
     }));
     stream.listen(null);
   });
diff --git a/test/null_stream_sink_test.dart b/test/null_stream_sink_test.dart
@@ -51,7 +51,7 @@ void main() {
 
       expect(() => sink.add(1), throwsStateError);
       expect(() => sink.addError('oh no'), throwsStateError);
-      expect(() => sink.addStream(Stream.empty()), throwsStateError);
+      expect(() => sink.addStream(const Stream.empty()), throwsStateError);
     });
 
     group('addStream', () {
@@ -93,15 +93,15 @@ void main() {
       test('causes events to throw StateErrors until the future completes',
           () async {
         var sink = NullStreamSink();
-        var future = sink.addStream(Stream.empty());
+        var future = sink.addStream(const Stream.empty());
         expect(() => sink.add(1), throwsStateError);
         expect(() => sink.addError('oh no'), throwsStateError);
-        expect(() => sink.addStream(Stream.empty()), throwsStateError);
+        expect(() => sink.addStream(const Stream.empty()), throwsStateError);
 
         await future;
         sink.add(1);
         sink.addError('oh no');
-        expect(sink.addStream(Stream.empty()), completes);
+        expect(sink.addStream(const Stream.empty()), completes);
       });
     });
   });
diff --git a/test/reject_errors_test.dart b/test/reject_errors_test.dart
@@ -171,7 +171,7 @@ void main() {
 
     test('throws on addStream()', () {
       var sink = controller.sink.rejectErrors()..close();
-      expect(() => sink.addStream(Stream.empty()), throwsStateError);
+      expect(() => sink.addStream(const Stream.empty()), throwsStateError);
     });
 
     test('allows close()', () {
@@ -196,7 +196,7 @@ void main() {
     test('throws on addStream()', () {
       var sink = controller.sink.rejectErrors()
         ..addStream(StreamController().stream);
-      expect(() => sink.addStream(Stream.empty()), throwsStateError);
+      expect(() => sink.addStream(const Stream.empty()), throwsStateError);
     });
 
     test('throws on close()', () {
diff --git a/test/restartable_timer_test.dart b/test/restartable_timer_test.dart
@@ -10,97 +10,98 @@ void main() {
   test('runs the callback once the duration has elapsed', () {
     FakeAsync().run((async) {
       var fired = false;
-      RestartableTimer(Duration(seconds: 5), () {
+      RestartableTimer(const Duration(seconds: 5), () {
         fired = true;
       });
 
-      async.elapse(Duration(seconds: 4));
+      async.elapse(const Duration(seconds: 4));
       expect(fired, isFalse);
 
-      async.elapse(Duration(seconds: 1));
+      async.elapse(const Duration(seconds: 1));
       expect(fired, isTrue);
     });
   });
 
   test("doesn't run the callback if the timer is canceled", () {
     FakeAsync().run((async) {
       var fired = false;
-      var timer = RestartableTimer(Duration(seconds: 5), () {
+      var timer = RestartableTimer(const Duration(seconds: 5), () {
         fired = true;
       });
 
-      async.elapse(Duration(seconds: 4));
+      async.elapse(const Duration(seconds: 4));
       expect(fired, isFalse);
       timer.cancel();
 
-      async.elapse(Duration(seconds: 4));
+      async.elapse(const Duration(seconds: 4));
       expect(fired, isFalse);
     });
   });
 
   test('resets the duration if the timer is reset before it fires', () {
     FakeAsync().run((async) {
       var fired = false;
-      var timer = RestartableTimer(Duration(seconds: 5), () {
+      var timer = RestartableTimer(const Duration(seconds: 5), () {
         fired = true;
       });
 
-      async.elapse(Duration(seconds: 4));
+      async.elapse(const Duration(seconds: 4));
       expect(fired, isFalse);
       timer.reset();
 
-      async.elapse(Duration(seconds: 4));
+      async.elapse(const Duration(seconds: 4));
       expect(fired, isFalse);
 
-      async.elapse(Duration(seconds: 1));
+      async.elapse(const Duration(seconds: 1));
       expect(fired, isTrue);
     });
   });
 
   test('re-runs the callback if the timer is reset after firing', () {
     FakeAsync().run((async) {
       var fired = 0;
-      var timer = RestartableTimer(Duration(seconds: 5), () {
+      var timer = RestartableTimer(const Duration(seconds: 5), () {
         fired++;
       });
 
-      async.elapse(Duration(seconds: 5));
+      async.elapse(const Duration(seconds: 5));
       expect(fired, equals(1));
       timer.reset();
 
-      async.elapse(Duration(seconds: 5));
+      async.elapse(const Duration(seconds: 5));
       expect(fired, equals(2));
       timer.reset();
 
-      async.elapse(Duration(seconds: 5));
+      async.elapse(const Duration(seconds: 5));
       expect(fired, equals(3));
     });
   });
 
   test('runs the callback if the timer is reset after being canceled', () {
     FakeAsync().run((async) {
       var fired = false;
-      var timer = RestartableTimer(Duration(seconds: 5), () {
+      var timer = RestartableTimer(const Duration(seconds: 5), () {
         fired = true;
       });
 
-      async.elapse(Duration(seconds: 4));
+      async.elapse(const Duration(seconds: 4));
       expect(fired, isFalse);
       timer.cancel();
 
-      async.elapse(Duration(seconds: 4));
+      async.elapse(const Duration(seconds: 4));
       expect(fired, isFalse);
       timer.reset();
 
-      async.elapse(Duration(seconds: 5));
+      async.elapse(const Duration(seconds: 5));
       expect(fired, isTrue);
     });
   });
 
   test("only runs the callback once if the timer isn't reset", () {
     FakeAsync().run((async) {
-      RestartableTimer(Duration(seconds: 5), expectAsync0(() {}, count: 1));
-      async.elapse(Duration(seconds: 10));
+      RestartableTimer(
+          const Duration(seconds: 5), expectAsync0(() {}, count: 1));
+      async.elapse(const Duration(seconds: 10));
     });
   });
 }
diff --git a/test/result/result_captureAll_test.dart b/test/result/result_captureAll_test.dart
@@ -147,7 +147,7 @@ void main() {
 
       expect(all, completion(expected));
 
-      var completeFunctions = List<Function()>.generate(n, (i) {
+      var completeFunctions = List<void Function()>.generate(n, (i) {
         var c = cs[i];
         return () =>
             throws(i) ? c.completeError('$i', someStack) : c.complete(i);
diff --git a/test/result/result_test.dart b/test/result/result_test.dart
@@ -61,7 +61,7 @@ void main() {
     var c = Completer<int>();
     c.future.then(expectAsync1((int v) {
       expect(v, equals(42));
-    }), onError: (e, s) {
+    }), onError: (Object? e, s) {
       fail('Unexpected error');
     });
     result.complete(c);
@@ -100,7 +100,7 @@ void main() {
     Result<int> result = ValueResult<int>(42);
     result.asFuture.then(expectAsync1((int v) {
       expect(v, equals(42));
-    }), onError: (e, s) {
+    }), onError: (Object? e, s) {
       fail('Unexpected error');
     });
   });
@@ -122,7 +122,7 @@ void main() {
       expect(result.isError, isFalse);
       var value = result.asValue!;
       expect(value.value, equals(42));
-    }), onError: (e, s) {
+    }), onError: (Object? e, s) {
       fail('Unexpected error: $e');
     });
   });
@@ -135,7 +135,7 @@ void main() {
       var error = result.asError!;
       expect(error.error, equals('BAD'));
       expect(error.stackTrace, same(stack));
-    }), onError: (e, s) {
+    }), onError: (Object? e, s) {
       fail('Unexpected error: $e');
     });
   });
@@ -144,7 +144,7 @@ void main() {
     var future = Future<Result<int>>.value(Result<int>.value(42));
     Result.release(future).then(expectAsync1((v) {
       expect(v, equals(42));
-    }), onError: (e, s) {
+    }), onError: (Object? e, s) {
       fail('Unexpected error: $e');
     });
   });
@@ -207,7 +207,7 @@ void main() {
       expect(v, equals(expected.asValue!.value));
     }
 
-    void errorListener(error, StackTrace stackTrace) {
+    void errorListener(Object error, StackTrace stackTrace) {
       expect(expectedList.isEmpty, isFalse);
       Result expected = expectedList.removeFirst();
       expect(expected.isError, isTrue);
@@ -263,7 +263,7 @@ void main() {
   test('handle unary', () {
     var result = ErrorResult('error', stack);
     var called = false;
-    result.handle((error) {
+    result.handle((Object? error) {
       called = true;
       expect(error, 'error');
     });
@@ -273,7 +273,7 @@ void main() {
   test('handle binary', () {
     var result = ErrorResult('error', stack);
     var called = false;
-    result.handle((error, stackTrace) {
+    result.handle((Object? error, Object? stackTrace) {
       called = true;
       expect(error, 'error');
       expect(stackTrace, same(stack));
@@ -284,7 +284,7 @@ void main() {
   test('handle unary and binary', () {
     var result = ErrorResult('error', stack);
     var called = false;
-    result.handle((error, [stackTrace]) {
+    result.handle((Object? error, [Object? stackTrace]) {
       called = true;
       expect(error, 'error');
       expect(stackTrace, same(stack));
@@ -344,11 +344,11 @@ class TestSink<T> implements EventSink<T> {
     onDone();
   }
 
-  static void _nullData(value) {
+  static void _nullData(dynamic value) {
     fail('Unexpected sink add: $value');
   }
 
-  static void _nullError(e, StackTrace s) {
+  static void _nullError(dynamic e, StackTrace s) {
     fail('Unexpected sink addError: $e');
   }
 
diff --git a/test/sink_base_test.dart b/test/sink_base_test.dart
@@ -328,7 +328,7 @@ void main() {
         sink.flush();
         expect(() => sink.add([0]), throwsStateError);
         expect(() => sink.addError('oh no'), throwsStateError);
-        expect(() => sink.addStream(Stream.empty()), throwsStateError);
+        expect(() => sink.addStream(const Stream.empty()), throwsStateError);
         expect(() => sink.flush(), throwsStateError);
         expect(() => sink.close(), throwsStateError);
       });
diff --git a/test/stream_closer_test.dart b/test/stream_closer_test.dart
diff --git a/test/stream_completer_test.dart b/test/stream_completer_test.dart
diff --git a/test/stream_extensions_test.dart b/test/stream_extensions_test.dart
diff --git a/test/stream_queue_test.dart b/test/stream_queue_test.dart
diff --git a/test/stream_sink_transformer_test.dart b/test/stream_sink_transformer_test.dart
diff --git a/test/subscription_stream_test.dart b/test/subscription_stream_test.dart
diff --git a/test/utils.dart b/test/utils.dart
