Very simple version of Isolates.

pkg/scheduled_test/test/metatest.dart

 // 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.
 
 /// A test library for testing test libraries? We must go deeper.
 ///
 /// Since unit testing code tends to use a lot of global state, it can be tough
 /// to test. This library manages it by running each test case in a child
 /// isolate, then reporting the results back to the parent isolate.
 library metatest;
@@ skipping 89 matching lines @@
 String _testToRun;
 
 /// The port with which the child isolate should communicate with the parent
 /// isolate. `null` in the parent isolate. Not set until [_inChildIsolate]
 /// completes.
 SendPort _replyTo;
 
 /// The cached [Future] for [_inChildIsolate].
 Future<bool> _inChildIsolateFuture;
 
+/// The initial message the isolate received.

[Lasse Reichstein Nielsen, 2013/10/25 09:42:49]

the isolate received -> received by the isolate.

[floitsch, 2013/10/25 13:11:01]

Done.

+var initialMessage;
+
 /// Returns whether or not we're running in a child isolate that's supposed to
 /// run a test.
 Future<bool> get _inChildIsolate {
   if (_inChildIsolateFuture != null) return _inChildIsolateFuture;
 
-  var completer = new Completer();
-  port.receive((message, replyTo) {
-    _testToRun = message['testToRun'];
-    _executable = message['executable'];
-    _replyTo = replyTo;
-    port.close();
-    completer.complete(true);
-  });
-
-  // TODO(nweiz): don't use a timeout here once issue 8416 is fixed.
-  _inChildIsolateFuture = timeout(completer.future, 500, () {
-    port.close();
-    return false;
-  });
+  if (initialMessage == null) {
+    _inChildIsolateFuture = new Future.value(false);
+  } else {
+    _testToRun = initialMessage['testToRun'];
+    _executable = initialMessage['executable'];
+    _replyTo = initialMessage['replyTo'];
+    _inChildIsolateFuture = new Future.value(true);
+  }
   return _inChildIsolateFuture;
 }
 
 /// Runs the test described by [description] in its own isolate. Returns a map
 /// describing the results of that test run.
 Future<Map> _runInIsolate(String description) {
+  var replyPort = new ReceivePort();
   // TODO(nweiz): Don't use path here once issue 8440 is fixed.
-  var future = spawnUri(path.join(path.current, Platform.script)).call({
+  return Isolate.spawnUri(Uri.parse(path.join(path.current, Platform.script)),
+      [], {
     'testToRun': description,
-    'executable': Platform.executable
-  });
-  // TODO(nweiz): Remove this timeout once issue 8417 is fixed and we can
-  // capture top-level exceptions.
-  return timeout(future, 30 * 1000, () {
-    throw 'Timed out waiting for test to complete.';
+    'executable': Platform.executable,
+    'replyTo': replyPort.sendPort
+  }).then((_) {
+    var future = replyPort.first;
+
+    // TODO(nweiz): Remove this timeout once issue 8417 is fixed and we can
+    // capture top-level exceptions.
+    return timeout(future, 30 * 1000, () {
+      throw 'Timed out waiting for test to complete.';
+    });
   });
 }
 
 /// Returns whether [results] (a test result map) describes a test run in which
 /// an error occurred.
 bool _hasError(Map results) {
   return results['errors'] > 0 || results['uncaughtError'] != null ||
     (results['passed'] == 0 && results['failed'] == 0);
 }
 
@@ skipping 59 matching lines @@
       "uncaughtError": uncaughtError,
       "results": results.map((testCase) => {
         "description": testCase.description,
         "message": testCase.message,
         "result": testCase.result,
         "stackTrace": testCase.stackTrace
       }).toList()
     });
   }
 }