Index: tests/language/async_star_await_pauses_test.dart |
diff --git a/tests/language/async_star_await_pauses_test.dart b/tests/language/async_star_await_pauses_test.dart |
new file mode 100644 |
index 0000000000000000000000000000000000000000..c16fbdd7ff898666c1462fca8a336a020e9679ee |
--- /dev/null |
+++ b/tests/language/async_star_await_pauses_test.dart |
@@ -0,0 +1,34 @@ |
+// Copyright (c) 2015, the Dart project authors. Please see the AUTHORS file |
+// for details. All rights reserved. Use of this source code is governed by a |
+// BSD-style license that can be found in the LICENSE file. |
+ |
+import "dart:async"; |
+import "package:expect/expect.dart"; |
+import "package:async_helper/async_helper.dart"; |
+ |
+main() { |
+ var sc; |
+ var i = 0; |
+ void send() { |
+ if (i == 5) { |
+ sc.close(); |
+ } else { |
+ sc.add(i++); |
+ } |
+ } |
+ sc = new StreamController(onListen: send, onResume: send); |
+ |
+ f(s) async { |
+ var r = 0; |
+ await for (var i in s) { |
+ r += await new Future.delayed(new Duration(milliseconds: 10), () => i); |
+ } |
+ return r; |
+ } |
+ |
+ asyncStart(); |
+ f(sc.stream).then((v) { |
+ Expect.equals(10, v); |
+ asyncEnd(); |
+ }); |
+} |