Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(319)

Unified Diff: tests/isolate/pause_test.dart

Issue 142703010: Add pause methods to Isolate. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Address comments. Created 6 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « tests/isolate/isolate.status ('k') | no next file » | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: tests/isolate/pause_test.dart
diff --git a/tests/isolate/pause_test.dart b/tests/isolate/pause_test.dart
new file mode 100644
index 0000000000000000000000000000000000000000..71691adfc8ca4257d6823afaee05e60541fdafec
--- /dev/null
+++ b/tests/isolate/pause_test.dart
@@ -0,0 +1,44 @@
+// Copyright (c) 2014, 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:isolate";
+import "dart:async";
+import "package:async_helper/async_helper.dart";
+
+isomain1(replyPort) {
+ RawReceivePort port = new RawReceivePort();
+ port.handler = (v) {
+ replyPort.send(v);
+ port.close();
+ };
+ replyPort.send(port.sendPort);
+}
+
+main(){
+ asyncStart();
+ RawReceivePort reply = new RawReceivePort();
+ Isolate isolate;
+ Capability resume;
+ var completer = new Completer(); // Completed by first reply from isolate.
+ reply.handler = completer.complete;
+ Isolate.spawn(isomain1, reply.sendPort).then((Isolate iso) {
+ isolate = iso;
+ resume = isolate.pause();
+ return completer.future;
+ }).then((echoPort) {
+ // Isolate has been created, and first response has been returned.
+ echoPort.send(24);
+ reply.handler = (v) {
+ throw "RESPONSE WHILE PAUSED?!?";
+ };
+ return new Future.delayed(const Duration(milliseconds: 250));
+ }).then((_) {
+ reply.handler = (v) {
+ if (v != 24) throw "WRONG ANSWER!";
+ reply.close();
+ asyncEnd();
+ };
+ isolate.resume(resume);
+ });
+}
« no previous file with comments | « tests/isolate/isolate.status ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698