Index: lib/src/runner/vm_listener.dart |
diff --git a/lib/src/runner/vm_listener.dart b/lib/src/runner/vm_listener.dart |
deleted file mode 100644 |
index f010c41f107a8f8c37dd53ba039a443d14b49716..0000000000000000000000000000000000000000 |
--- a/lib/src/runner/vm_listener.dart |
+++ /dev/null |
@@ -1,115 +0,0 @@ |
-// 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. |
- |
-library unittest.runner.vm_listener; |
- |
-import 'dart:isolate'; |
-import 'dart:async'; |
- |
-import '../backend/declarer.dart'; |
-import '../backend/suite.dart'; |
-import '../backend/test.dart'; |
-import '../util/remote_exception.dart'; |
-import '../utils.dart'; |
- |
-/// A class that runs tests in a separate isolate and communicates the results |
-/// back to the main isolate. |
-class VmListener { |
- /// The test suite to run. |
- final Suite _suite; |
- |
- /// Extracts metadata about all the tests in the function returned by |
- /// [getMain] and sends information about them over [sendPort]. |
- /// |
- /// The main function is wrapped in a closure so that we can handle it being |
- /// undefined here rather than in the generated code. |
- /// |
- /// Once that's done, this starts listening for commands about which tests to |
- /// run. |
- static void start(SendPort sendPort, Function getMain()) { |
- var main; |
- try { |
- main = getMain(); |
- } on NoSuchMethodError catch (_) { |
- _sendLoadException(sendPort, "No top-level main() function defined."); |
- return; |
- } |
- |
- if (main is! Function) { |
- _sendLoadException(sendPort, "Top-level main getter is not a function."); |
- return; |
- } else if (main is! AsyncFunction) { |
- _sendLoadException( |
- sendPort, "Top-level main() function takes arguments."); |
- return; |
- } |
- |
- var declarer = new Declarer(); |
- try { |
- runZoned(main, zoneValues: {#unittest.declarer: declarer}); |
- } catch (error, stackTrace) { |
- sendPort.send({ |
- "type": "error", |
- "error": RemoteException.serialize(error, stackTrace) |
- }); |
- return; |
- } |
- |
- new VmListener._(new Suite("VmListener", declarer.tests)) |
- ._listen(sendPort); |
- } |
- |
- /// Sends a message over [sendPort] indicating that the tests failed to load. |
- /// |
- /// [message] should describe the failure. |
- static void _sendLoadException(SendPort sendPort, String message) { |
- sendPort.send({"type": "loadException", "message": message}); |
- } |
- |
- VmListener._(this._suite); |
- |
- /// Send information about [_suite] across [sendPort] and start listening for |
- /// commands to run the tests. |
- void _listen(SendPort sendPort) { |
- var tests = []; |
- for (var i = 0; i < _suite.tests.length; i++) { |
- var test = _suite.tests[i]; |
- var receivePort = new ReceivePort(); |
- tests.add({"name": test.name, "sendPort": receivePort.sendPort}); |
- |
- receivePort.listen((message) { |
- assert(message['command'] == 'run'); |
- _runTest(test, message['reply']); |
- }); |
- } |
- |
- sendPort.send({ |
- "type": "success", |
- "tests": tests |
- }); |
- } |
- |
- /// Runs [test] and send the results across [sendPort]. |
- void _runTest(Test test, SendPort sendPort) { |
- var liveTest = test.load(_suite); |
- |
- liveTest.onStateChange.listen((state) { |
- sendPort.send({ |
- "type": "state-change", |
- "status": state.status.name, |
- "result": state.result.name |
- }); |
- }); |
- |
- liveTest.onError.listen((asyncError) { |
- sendPort.send({ |
- "type": "error", |
- "error": RemoteException.serialize( |
- asyncError.error, asyncError.stackTrace) |
- }); |
- }); |
- |
- liveTest.run().then((_) => sendPort.send({"type": "complete"})); |
- } |
-} |