Index: utils/pub/error_group.dart |
diff --git a/utils/pub/error_group.dart b/utils/pub/error_group.dart |
index e68306c629e012a588ca8bfda837f036f8929151..624e51cfd4ca5f56c83a8ab43c13eae2c3d6ed61 100644 |
--- a/utils/pub/error_group.dart |
+++ b/utils/pub/error_group.dart |
@@ -240,7 +240,7 @@ class _ErrorGroupStream extends Stream { |
/// [inner]. |
_ErrorGroupStream(this._group, Stream inner) |
: _controller = new StreamController() { |
- this.stream = isBroadcast |
+ this._stream = inner.isBroadcast |
? _controller.stream.asBroadcastStream() |
: _controller.stream; |
_subscription = inner.listen((v) { |
@@ -257,7 +257,7 @@ class _ErrorGroupStream extends Stream { |
StreamSubscription listen(void onData(value), |
{void onError(var error), void onDone(), |
bool cancelOnError}) { |
- return _controller.stream.listen(onData, |
+ return _stream.listen(onData, |
onError: onError, |
onDone: onDone, |
cancelOnError: true); |