| Index: utils/pub/utils.dart
|
| diff --git a/utils/pub/utils.dart b/utils/pub/utils.dart
|
| index 098916ea645c105b7283681b9ef16783102fd0a4..fd130da7ee1dfa4e62f3dec9aed430f058ae85a3 100644
|
| --- a/utils/pub/utils.dart
|
| +++ b/utils/pub/utils.dart
|
| @@ -202,7 +202,7 @@ Pair<Stream, StreamSubscription> streamWithSubscription(Stream stream) {
|
| new StreamController.broadcast() :
|
| new StreamController();
|
| var subscription = stream.listen(controller.add,
|
| - onError: controller.signalError,
|
| + onError: controller.addError,
|
| onDone: controller.close);
|
| return new Pair<Stream, StreamSubscription>(controller.stream, subscription);
|
| }
|
| @@ -218,8 +218,8 @@ Pair<Stream, Stream> tee(Stream stream) {
|
| controller1.add(value);
|
| controller2.add(value);
|
| }, onError: (error) {
|
| - controller1.signalError(error);
|
| - controller2.signalError(error);
|
| + controller1.addError(error);
|
| + controller2.addError(error);
|
| }, onDone: () {
|
| controller1.close();
|
| controller2.close();
|
|
|