Index: tests/language/asyncstar_yield_test.dart |
diff --git a/tests/language/asyncstar_yield_test.dart b/tests/language/asyncstar_yield_test.dart |
new file mode 100644 |
index 0000000000000000000000000000000000000000..6a546fac864a53dbd66e2fb962f7040bde018199 |
--- /dev/null |
+++ b/tests/language/asyncstar_yield_test.dart |
@@ -0,0 +1,70 @@ |
+// 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"; |
+ |
+Stream<int> foo1() async* { |
+ yield 1; |
+ var p = await new Future.value(10); |
+ yield p + 10; |
+} |
+ |
+Stream<int> foo2() async* { |
+ int i = 0; |
+ while (true) { |
+ await (new Future.delayed(new Duration(milliseconds: 0), () {})); |
+ if (i > 10) return; |
+ yield i; |
+ i++; |
+ } |
+} |
+ |
+Stream<int> foo3(p) async* { |
+ int i = 0; |
+ bool t = false; |
+ yield null; |
+ while (true) { |
+ i++; |
+ a: for (int i = 0; i < p; i++) { |
+ if (!t) { |
+ for (int j = 0; j < 3; j++) { |
+ yield -1; |
+ t = true; |
+ break a; |
+ } |
+ } |
+ await 4; |
+ yield i; |
+ } |
+ } |
+} |
+ |
+Completer<bool> finalized = new Completer<bool>(); |
+ |
+Stream<int> foo4() async* { |
+ int i = 0; |
+ try { |
+ while (true) { |
+ yield i; |
+ i++; |
+ } |
+ } finally { |
+ // Canceling the stream-subscription should run the finalizer. |
+ finalized.complete(true); |
+ } |
+} |
+ |
+main () async { |
+ asyncStart(); |
+ Expect.listEquals([1, 20], await (foo1().toList())); |
+ Expect.listEquals([0, 1, 2, 3], await (foo2().take(4).toList())); |
+ Expect.listEquals([null, -1, 0, 1, 2, 3, 0, 1, 2, 3], |
+ await (foo3(4).take(10).toList())); |
+ Expect.listEquals([0, 1, 2, 3, 4, 5, 6, 7, 8, 9], |
+ await (foo4().take(10).toList())); |
+ Expect.isTrue(await (finalized.future)); |
+ asyncEnd(); |
+} |