| OLD | NEW |
| 1 // Copyright (c) 2015, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2015, the Dart project authors. Please see the AUTHORS file |
| 2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
| 3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
| 4 | 4 |
| 5 library async_star_pause_test; | 5 library async_star_pause_test; |
| 6 | 6 |
| 7 import "package:unittest/unittest.dart"; | 7 import "package:async_helper/async_helper.dart"; |
| 8 import "package:expect/expect.dart"; |
| 8 import "dart:async"; | 9 import "dart:async"; |
| 9 | 10 |
| 10 main() { | 11 main() { |
| 11 test("await for pauses stream during body", () async { | 12 // await for pauses stream during body. |
| 13 asyncTest(() async { |
| 12 // Assumes await-for uses streamIterator. | 14 // Assumes await-for uses streamIterator. |
| 13 var log = []; | 15 var log = []; |
| 14 var s = () async* { | 16 var s = () async* { |
| 15 for (int i = 0; i < 3; i++) { | 17 for (int i = 0; i < 3; i++) { |
| 16 log.add("$i-"); | 18 log.add("$i-"); |
| 17 yield i; | 19 yield i; |
| 18 // Should pause here until next iteration of await-for loop. | 20 // Should pause here until next iteration of await-for loop. |
| 19 log.add("$i+"); | 21 log.add("$i+"); |
| 20 } | 22 } |
| 21 }(); | 23 }(); |
| 22 await for (var i in s) { | 24 await for (var i in s) { |
| 23 log.add("$i?"); | 25 log.add("$i?"); |
| 24 await nextMicrotask(); | 26 await nextMicrotask(); |
| 25 log.add("$i!"); | 27 log.add("$i!"); |
| 26 } | 28 } |
| 27 expect(log, [ | 29 Expect.listEquals(log, [ |
| 28 "0-", | 30 "0-", |
| 29 "0?", | 31 "0?", |
| 30 "0!", | 32 "0!", |
| 31 "0+", | 33 "0+", |
| 32 "1-", | 34 "1-", |
| 33 "1?", | 35 "1?", |
| 34 "1!", | 36 "1!", |
| 35 "1+", | 37 "1+", |
| 36 "2-", | 38 "2-", |
| 37 "2?", | 39 "2?", |
| 38 "2!", | 40 "2!", |
| 39 "2+" | 41 "2+" |
| 40 ]); | 42 ]); |
| 41 }); | 43 }); |
| 42 } | 44 } |
| 43 | 45 |
| 44 Future nextMicrotask() => new Future.microtask(() {}); | 46 Future nextMicrotask() => new Future.microtask(() {}); |
| OLD | NEW |