Use the dart:async Stream API thoroughly in Pub.

utils/pub/error_group.dart

Index: utils/pub/error_group.dart
diff --git a/utils/pub/error_group.dart b/utils/pub/error_group.dart
index b78ceacb77f11e6c20ef24c5ab14fdee71bf622f..0bdf5e5568d6b9e4d3a8a3d79feceba921170b6e 100644
--- a/utils/pub/error_group.dart
+++ b/utils/pub/error_group.dart
@@ -179,7 +179,7 @@ class _ErrorGroupFuture implements Future {
     _completer.future.catchError((_) {});
   }
 
-  Future then(onValue(T value), {onError(AsyncError asyncError)}) {
+  Future then(onValue(value), {onError(AsyncError asyncError)}) {
     _hasListeners = true;
     return _completer.future.then(onValue, onError: onError);
   }
@@ -194,7 +194,7 @@ class _ErrorGroupFuture implements Future {
     return _completer.future.whenComplete(action);
   }
 
-  Stream<T> asStream() {
+  Stream asStream() {
     _hasListeners = true;
     return _completer.future.asStream();
   }