Index: utils/pub/error_group.dart |
diff --git a/utils/pub/error_group.dart b/utils/pub/error_group.dart |
index a9f78617f7be0b9d7e1c5ecee3f4fa568c9ec11e..b78ceacb77f11e6c20ef24c5ab14fdee71bf622f 100644 |
--- a/utils/pub/error_group.dart |
+++ b/utils/pub/error_group.dart |
@@ -233,9 +233,9 @@ class _ErrorGroupStream extends Stream { |
/// Creates a new [_ErrorGroupFuture] that's a child of [_group] and wraps |
/// [inner]. |
_ErrorGroupStream(this._group, Stream inner) |
- : _controller = inner.isSingleSubscription ? |
- new StreamController() : |
- new StreamController.multiSubscription() { |
+ : _controller = inner.isBroadcast ? |
+ new StreamController.broadcast() : |
+ new StreamController() { |
_subscription = inner.listen(_controller.add, |
onError: (e) => _group._signalError(e), |
onDone: () { |