Index: utils/pub/io.dart |
diff --git a/utils/pub/io.dart b/utils/pub/io.dart |
index 50889289ab1edc7dba6a6a548f353b4d76cf0664..f40982dcb344dc9e4cac5da007ac3a5f38761028 100644 |
--- a/utils/pub/io.dart |
+++ b/utils/pub/io.dart |
@@ -343,17 +343,17 @@ Pair<EventSink, Future> consumerToSink(StreamConsumer consumer) { |
/// true. |
/// |
/// When an error occurs on [stream], that error is passed to [sink]. If |
-/// [unsubscribeOnError] is true, [Future] will be completed successfully and no |
+/// [cancelOnError] is true, [Future] will be completed successfully and no |
/// more data or errors will be piped from [stream] to [sink]. If |
-/// [unsubscribeOnError] and [closeSink] are both true, [sink] will then be |
+/// [cancelOnError] and [closeSink] are both true, [sink] will then be |
/// closed. |
Future store(Stream stream, EventSink sink, |
- {bool unsubscribeOnError: true, closeSink: true}) { |
+ {bool cancelOnError: true, closeSink: true}) { |
var completer = new Completer(); |
stream.listen(sink.add, |
onError: (e) { |
sink.addError(e); |
- if (unsubscribeOnError) { |
+ if (cancelOnError) { |
completer.complete(); |
if (closeSink) sink.close(); |
} |
@@ -361,7 +361,7 @@ Future store(Stream stream, EventSink sink, |
onDone: () { |
if (closeSink) sink.close(); |
completer.complete(); |
- }, unsubscribeOnError: unsubscribeOnError); |
+ }, cancelOnError: cancelOnError); |
return completer.future; |
} |