| Index: tests/lib/async/catch_errors10_test.dart
|
| diff --git a/tests/lib/async/catch_errors2_test.dart b/tests/lib/async/catch_errors10_test.dart
|
| similarity index 66%
|
| copy from tests/lib/async/catch_errors2_test.dart
|
| copy to tests/lib/async/catch_errors10_test.dart
|
| index e67d665019b5f67e1f5f77fc268d5fb4501526fa..573ecc80e79f19f90f59fec41e75eb735e4e2b4e 100644
|
| --- a/tests/lib/async/catch_errors2_test.dart
|
| +++ b/tests/lib/async/catch_errors10_test.dart
|
| @@ -8,18 +8,20 @@ import 'dart:isolate';
|
|
|
| main() {
|
| // We keep a ReceivePort open until all tests are done. This way the VM will
|
| - // time out if the callbacks are not invoked.
|
| + // hang if the callbacks are not invoked and the test will time out.
|
| var port = new ReceivePort();
|
| bool futureWasExecuted = false;
|
| - // Make sure that `catchErrors` only closes the error stream when the inner
|
| - // futures are done.
|
| + // Test that `catchErrors` waits for a future that has been delayed by
|
| + // `Timer.run`.
|
| catchErrors(() {
|
| - new Future(() {
|
| - futureWasExecuted = true;
|
| + Timer.run(() {
|
| + new Future.value(499).then((x) {
|
| + futureWasExecuted = true;
|
| + });
|
| });
|
| return 'allDone';
|
| }).listen((x) {
|
| - Expect.fail("Unexped callback");
|
| + Expect.fail("Unexpected callback");
|
| },
|
| onDone: () {
|
| Expect.isTrue(futureWasExecuted);
|
|
|