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