Index: tests/lib/async/event_helper.dart |
diff --git a/tests/lib/async/event_helper.dart b/tests/lib/async/event_helper.dart |
index db5189c0468e7e19be4de55d612d209f48049e3b..0d6ef1aef2cb1c4d334cd7948e548ded8133cd75 100644 |
--- a/tests/lib/async/event_helper.dart |
+++ b/tests/lib/async/event_helper.dart |
@@ -70,7 +70,7 @@ class Events implements EventSink { |
/** Capture events from a stream into a new [Events] object. */ |
factory Events.capture(Stream stream, |
- { bool unsubscribeOnError: false }) = CaptureEvents; |
+ { bool cancelOnError: false }) = CaptureEvents; |
// EventSink interface. |
void add(var value) { |
@@ -134,21 +134,21 @@ class Events implements EventSink { |
class CaptureEvents extends Events { |
StreamSubscription subscription; |
Completer onDoneSignal; |
- bool unsubscribeOnError = false; |
+ bool cancelOnError = false; |
CaptureEvents(Stream stream, |
- { bool unsubscribeOnError: false }) |
+ { bool cancelOnError: false }) |
: onDoneSignal = new Completer() { |
- this.unsubscribeOnError = unsubscribeOnError; |
+ this.cancelOnError = cancelOnError; |
subscription = stream.listen(add, |
onError: addError, |
onDone: close, |
- unsubscribeOnError: unsubscribeOnError); |
+ cancelOnError: cancelOnError); |
} |
void addError(AsyncError error) { |
super.addError(error); |
- if (unsubscribeOnError) onDoneSignal.complete(null); |
+ if (cancelOnError) onDoneSignal.complete(null); |
} |
void close() { |