Index: tests/lib/async/run_async4_test.dart |
diff --git a/tests/lib/async/run_async4_test.dart b/tests/lib/async/run_async4_test.dart |
new file mode 100644 |
index 0000000000000000000000000000000000000000..1c105205a897b90c41c7d18dca569636abca96e8 |
--- /dev/null |
+++ b/tests/lib/async/run_async4_test.dart |
@@ -0,0 +1,39 @@ |
+// Copyright (c) 2013, 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. |
+ |
+library run_async_test; |
+ |
+import 'dart:async'; |
+import 'dart:isolate'; |
+ |
+void startTest(SendPort finishPort, replyPort) { |
+ int invokedCallbacks = 0; |
+ |
+ for (int i = 0; i < 100; i++) { |
+ runAsync(() { |
+ invokedCallbacks++; |
+ if (invokedCallbacks == 100) finishPort.send("done"); |
+ if (i == 50) throw new RuntimeError("ignore exception"); |
+ }); |
+ } |
+ |
+ // Without this Timer the isolate will freeze. |
+ // TODO(9013): Remove this Timer. |
+ new Timer(const Duration(seconds: 2), () { }); |
+} |
+ |
+runTest() { |
+ port.receive(startTest); |
+} |
+ |
+bool globalErrorHandler(IsolateUnhandledException e) { |
+ return e.source is RuntimeError && e.source.message == "ignore exception"; |
+} |
+ |
+main() { |
+ var port = new ReceivePort(); |
+ SendPort otherIsolate = spawnFunction(runTest, globalErrorHandler); |
+ otherIsolate.send(port.toSendPort()); |
+ port.receive((msg, replyPort) { port.close(); }); |
+} |