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