| Index: tests/language/asyncstar_yieldstar_test.dart
|
| diff --git a/tests/language/asyncstar_yieldstar_test.dart b/tests/language/asyncstar_yieldstar_test.dart
|
| index 4caaf2d03216f1b5a750d1a4ba2049c3a187f826..55130d745efe44dae20720ec4e44d29b8f60381a 100644
|
| --- a/tests/language/asyncstar_yieldstar_test.dart
|
| +++ b/tests/language/asyncstar_yieldstar_test.dart
|
| @@ -8,7 +8,7 @@ import "package:async_helper/async_helper.dart";
|
|
|
| Stream<int> subStream(p) async* {
|
| yield p;
|
| - yield p+1;
|
| + yield p + 1;
|
| }
|
|
|
| Stream foo(Completer<bool> finalized) async* {
|
| @@ -32,24 +32,23 @@ foo2(Stream subStream) async* {
|
| }
|
|
|
| test() async {
|
| - Expect.listEquals([0, 1],
|
| - await (subStream(0).toList()));
|
| + Expect.listEquals([0, 1], await (subStream(0).toList()));
|
| Completer<bool> finalized = new Completer<bool>();
|
| Expect.listEquals(["outer", 0, 1, "outer", 1, 2, "outer", 2],
|
| await (foo(finalized).take(8).toList()));
|
| Expect.isTrue(await (finalized.future));
|
| -
|
| +
|
| finalized = new Completer<bool>();
|
| // Canceling the stream while it is yield*-ing from the sub-stream.
|
| Expect.listEquals(["outer", 0, 1, "outer", 1, 2, "outer"],
|
| await (foo(finalized).take(7).toList()));
|
| Expect.isTrue(await (finalized.future));
|
| finalized = new Completer<bool>();
|
| -
|
| +
|
| Completer<bool> pausedCompleter = new Completer<bool>();
|
| Completer<bool> resumedCompleter = new Completer<bool>();
|
| Completer<bool> canceledCompleter = new Completer<bool>();
|
| -
|
| +
|
| StreamController controller;
|
| int i = 0;
|
| addNext() {
|
| @@ -60,7 +59,7 @@ test() async {
|
| scheduleMicrotask(addNext);
|
| }
|
| }
|
| -
|
| +
|
| controller = new StreamController(onListen: () {
|
| scheduleMicrotask(addNext);
|
| }, onPause: () {
|
| @@ -71,7 +70,7 @@ test() async {
|
| }, onCancel: () {
|
| canceledCompleter.complete(true);
|
| });
|
| -
|
| +
|
| StreamSubscription subscription;
|
| // Test that the yield*'ed stream is paused and resumed.
|
| subscription = foo2(controller.stream).listen((event) {
|
| @@ -97,4 +96,4 @@ main() {
|
| test().then((_) {
|
| asyncEnd();
|
| });
|
| -}
|
| +}
|
|
|