Implementation of async-await transformation on js ast.

tests/language/asyncstar_yield_test.dart

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..ffd9e1a25332c873d40a0e94cdb66d09c0f80697
--- /dev/null
+++ b/tests/language/asyncstar_yield_test.dart
@@ -0,0 +1,102 @@
+// 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";
+
+// Create a stream that produces numbers [1, 2, ... maxCount]
+Stream timedCounter(int maxCount) {

[floitsch, 2015/02/04 12:31:29]

class seems unused.

[sigurdm, 2015/02/05 14:06:06]

Removed

+  StreamController controller;
+  Timer timer;
+  int counter = 0;
+
+  void tick(_) {
+    counter++;
+    controller.add(counter); // Ask stream to send counter values as event.
+    if (counter >= maxCount) {
+      timer.cancel();
+      controller.close(); // Ask stream to shut down and tell listeners.
+    }
+  }
+
+  void startTimer() {
+    timer = new Timer.periodic(const Duration(milliseconds: 10), tick);
+  }
+
+  void stopTimer() {
+    if (timer != null) {
+      timer.cancel();
+      timer = null;
+    }
+  }
+
+  controller = new StreamController(
+      onListen: startTimer,
+      onPause: stopTimer,
+      onResume: startTimer,
+      onCancel: stopTimer);
+
+  return controller.stream;
+}
+
+
+Stream<int> foo1() async* {
+  yield 1;
+  var p = await new Future.delayed(new Duration(milliseconds: 10), () => 10);
+  yield p + 10;
+}
+
+Stream<int> foo2() async* {
+  int i = 0;
+  while (true) {
+    await (new Future.delayed(new Duration(milliseconds: 700), () {}));
+    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 {

[floitsch, 2015/02/04 12:31:29]

you still need the async helper package.

[sigurdm, 2015/02/05 14:06:06]

Done.

+  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()));

[floitsch, 2015/02/04 12:31:29]

long lines.

[sigurdm, 2015/02/05 14:06:06]

Done.

+  Expect.listEquals([0, 1, 2, 3, 4, 5, 6, 7, 8, 9], await (foo4().take(10).toList()));
+  Expect.isTrue(await (finalized.future));
+}