| Index: tests/language/asyncstar_throw_in_catch_test.dart
|
| ===================================================================
|
| --- tests/language/asyncstar_throw_in_catch_test.dart (revision 0)
|
| +++ tests/language/asyncstar_throw_in_catch_test.dart (working copy)
|
| @@ -0,0 +1,65 @@
|
| +// 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";
|
| +
|
| +class Tracer {
|
| + final String expected;
|
| + final String name;
|
| + int counter = 0;
|
| +
|
| + Tracer(this.expected, [this.name]);
|
| +
|
| + void trace(msg) {
|
| + if (name != null) {
|
| + print("Tracing $name: $msg");
|
| + }
|
| + Expect.equals(expected[counter], msg);
|
| + counter++;
|
| + }
|
| +
|
| + void done() {
|
| + Expect.equals(expected.length, counter, "Received too few traces");
|
| + }
|
| +}
|
| +
|
| +foo1(Tracer tracer) async* {
|
| + try {
|
| + tracer.trace("a");
|
| + await new Future.value(3);
|
| + tracer.trace("b");
|
| + throw "Error";
|
| + } catch (e) {
|
| + tracer.trace("c");
|
| + yield 1;
|
| + tracer.trace("d");
|
| + yield 2;
|
| + tracer.trace("e");
|
| + await new Future.error("Error2");
|
| + } finally {
|
| + tracer.trace("f");
|
| + }
|
| + tracer.trace("g");
|
| +}
|
| +
|
| +test() async {
|
| + Tracer tracer;
|
| +
|
| + Completer foo1Done = new Completer();
|
| + tracer = new Tracer("abcdf");
|
| + var subscription;
|
| + subscription = foo1(tracer).listen((event) async {
|
| + await subscription.cancel();
|
| + tracer.done();
|
| + foo1Done.complete(null);
|
| + });
|
| + await foo1Done.future;
|
| +}
|
| +
|
| +
|
| +void main() {
|
| + asyncTest(test);
|
| +}
|
|
|