| 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);
|
|
|