Updated pub_sub

packages/pub_sub/CHANGELOG.md

@@ -1,3 +1,5 @@
+# 3.0.1
+* Resolved static analysis warnings
 # 3.0.0
 * Migrated to work with Dart SDK 2.12.x NNBD
 

packages/pub_sub/README.md

@@ -1,5 +1,5 @@
 # angel3_pub_sub
-[![version](https://img.shields.io/badge/pub-v3.0.0-brightgreen)](https://pub.dartlang.org/packages/angel3_pub_sub)
+[![version](https://img.shields.io/badge/pub-v3.0.1-brightgreen)](https://pub.dartlang.org/packages/angel3_pub_sub)
 [![Null Safety](https://img.shields.io/badge/null-safety-brightgreen)](https://dart.dev/null-safety)
 [![Gitter](https://img.shields.io/gitter/room/angel_dart/discussion)](https://gitter.im/angel_dart/discussion)
 

packages/pub_sub/example/main.dart

@@ -12,7 +12,7 @@ void main() async {
   // Every untrusted client in your application should be pre-registered.
   //
   // In the case of Isolates, however, those are always implicitly trusted.
-  for (int i = 0; i < Platform.numberOfProcessors - 1; i++) {
+  for (var i = 0; i < Platform.numberOfProcessors - 1; i++) {
     server.registerClient(pub_sub.ClientInfo('client$i'));
   }
 

packages/pub_sub/lib/src/json_rpc/client.dart

@@ -100,7 +100,9 @@ class JsonRpc2Client extends Client {
       }
     }
 
-    for (var s in _subscriptions) s._close();
+    for (var s in _subscriptions) {
+      s._close();
+    }
 
     _requests.clear();
     return Future.value();
@@ -119,7 +121,7 @@ class _JsonRpc2ClientSubscription extends ClientSubscription {
   }
 
   @override
-  StreamSubscription listen(void onData(event)?,
+  StreamSubscription listen(void Function(dynamic event)? onData,
       {Function? onError, void Function()? onDone, bool? cancelOnError}) {
     return _stream.stream.listen(onData,
         onError: onError, onDone: onDone, cancelOnError: cancelOnError);

packages/pub_sub/pubspec.yaml

@@ -1,5 +1,5 @@
 name: angel3_pub_sub
-version: 3.0.0
+version: 3.0.1
 description: Keep application instances in sync with a simple pub/sub API.
 homepage: https://github.com/dukefirehawk/angel/tree/angel3/packages/pub_sub
 environment:

packages/pub_sub/test/json_rpc_2_test.dart

@@ -51,12 +51,8 @@ void main() {
   });
 
   tearDown(() {
-    Future.wait([
-      server?.close(),
-      client1?.close(),
-      client2?.close(),
-      client3?.close()
-    ]);
+    Future.wait(
+        [server.close(), client1.close(), client2.close(), client3.close()]);
   });
 
   group('trusted', () {