| 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 89788df4c6778696bfd1abd1aff103787ecfd9e5..e06ec4ad512c92d2775001bac7ae6624c92d5c14 100644
|
| --- a/tests/lib/async/stream_controller_test.dart
|
| +++ b/tests/lib/async/stream_controller_test.dart
|
| @@ -33,7 +33,7 @@ testController() {
|
| expectedEvents = new Events()..add(42)..error("error")..add(37);
|
| actualEvents = new Events.capture(c, unsubscribeOnError: false);
|
| expectedEvents.replay(c);
|
| - actualEvents.subscription.unsubscribe();
|
| + actualEvents.subscription.cancel();
|
| c.add("Are you there"); // Not sent to actualEvents.
|
| Expect.listEquals(expectedEvents.events, actualEvents.events);
|
|
|
| @@ -128,14 +128,14 @@ testController() {
|
| var subscription = stream.listen(null);
|
| subscription.onData((data) {
|
| counter += data;
|
| - subscription.unsubscribe();
|
| + subscription.cancel();
|
| stream.listen((data) {
|
| counter += 10 * data;
|
| });
|
| var subscription2 = stream.listen(null);
|
| subscription2.onData((data) {
|
| counter += 100 * data;
|
| - if (data == 4) subscription2.unsubscribe();
|
| + if (data == 4) subscription2.cancel();
|
| });
|
| });
|
| sink.add(1); // seen by stream 1
|
| @@ -173,7 +173,7 @@ testSingleController() {
|
| expectedEvents = new Events()..add(42)..error("error")..add(37);
|
| actualEvents = new Events.capture(c, unsubscribeOnError: false);
|
| expectedEvents.replay(c);
|
| - actualEvents.subscription.unsubscribe();
|
| + actualEvents.subscription.cancel();
|
| c.add("Are you there"); // Not sent to actualEvents.
|
| Expect.listEquals(expectedEvents.events, actualEvents.events);
|
|
|
|
|