| Index: tests/lib/async/stream_controller_test.dart
|
| diff --git a/tests/lib/async/stream_controller_test.dart b/tests/lib/async/stream_controller_test.dart
|
| index 7eba3c15f0ed1c7f522c5cd902bf60f18778234b..bd830b4ff877b1c8b95bc54a66dc708a43aed214 100644
|
| --- a/tests/lib/async/stream_controller_test.dart
|
| +++ b/tests/lib/async/stream_controller_test.dart
|
| @@ -25,7 +25,7 @@ testMultiController() {
|
| // Test automatic unsubscription on error.
|
| c = new StreamController.broadcast();
|
| expectedEvents = new Events()..add(42)..error("error");
|
| - actualEvents = new Events.capture(c.stream, unsubscribeOnError: true);
|
| + actualEvents = new Events.capture(c.stream, cancelOnError: true);
|
| Events sentEvents =
|
| new Events()..add(42)..error("error")..add("Are you there?");
|
| sentEvents.replay(c);
|
| @@ -34,7 +34,7 @@ testMultiController() {
|
| // Test manual unsubscription.
|
| c = new StreamController.broadcast();
|
| expectedEvents = new Events()..add(42)..error("error")..add(37);
|
| - actualEvents = new Events.capture(c.stream, unsubscribeOnError: false);
|
| + actualEvents = new Events.capture(c.stream, cancelOnError: false);
|
| expectedEvents.replay(c);
|
| actualEvents.subscription.cancel();
|
| c.add("Are you there"); // Not sent to actualEvents.
|
| @@ -67,7 +67,7 @@ testMultiController() {
|
| throw new AsyncError("[${v.error}]",
|
| "other stack");
|
| }
|
| - }), unsubscribeOnError: true);
|
| + }), cancelOnError: true);
|
| sentEvents.replay(c);
|
| Expect.listEquals(expectedEvents.events, actualEvents.events);
|
|
|
| @@ -123,7 +123,7 @@ testMultiController() {
|
| if (v.error is! FormatException) throw v;
|
| })
|
| .where((v) => v > 10),
|
| - unsubscribeOnError: true);
|
| + cancelOnError: true);
|
| sentEvents.replay(c);
|
| Expect.listEquals(expectedEvents.events, actualEvents.events);
|
|
|
| @@ -169,7 +169,7 @@ testSingleController() {
|
| // Test automatic unsubscription on error.
|
| c = new StreamController();
|
| expectedEvents = new Events()..add(42)..error("error");
|
| - actualEvents = new Events.capture(c.stream, unsubscribeOnError: true);
|
| + actualEvents = new Events.capture(c.stream, cancelOnError: true);
|
| Events sentEvents =
|
| new Events()..add(42)..error("error")..add("Are you there?");
|
| sentEvents.replay(c);
|
| @@ -178,7 +178,7 @@ testSingleController() {
|
| // Test manual unsubscription.
|
| c = new StreamController();
|
| expectedEvents = new Events()..add(42)..error("error")..add(37);
|
| - actualEvents = new Events.capture(c.stream, unsubscribeOnError: false);
|
| + actualEvents = new Events.capture(c.stream, cancelOnError: false);
|
| expectedEvents.replay(c);
|
| actualEvents.subscription.cancel();
|
| c.add("Are you there"); // Not sent to actualEvents.
|
| @@ -211,7 +211,7 @@ testSingleController() {
|
| throw new AsyncError("[${v.error}]",
|
| "other stack");
|
| }
|
| - }), unsubscribeOnError: true);
|
| + }), cancelOnError: true);
|
| sentEvents.replay(c);
|
| Expect.listEquals(expectedEvents.events, actualEvents.events);
|
|
|
| @@ -300,7 +300,7 @@ testSingleController() {
|
| if (v.error is! FormatException) throw v;
|
| })
|
| .where((v) => v > 10),
|
| - unsubscribeOnError: true);
|
| + cancelOnError: true);
|
| sentEvents.replay(c);
|
| Expect.listEquals(expectedEvents.events, actualEvents.events);
|
|
|
|
|