| Index: lib/src/runner/engine.dart
|
| diff --git a/lib/src/runner/engine.dart b/lib/src/runner/engine.dart
|
| index 824f34e282ba614b6b8b3435ae9c9a5d3c9accfd..c93e793a2de1ce102f06573e1a309348e9caee91 100644
|
| --- a/lib/src/runner/engine.dart
|
| +++ b/lib/src/runner/engine.dart
|
| @@ -14,9 +14,9 @@ import 'package:pool/pool.dart';
|
| import '../backend/live_test.dart';
|
| import '../backend/live_test_controller.dart';
|
| import '../backend/state.dart';
|
| -import '../backend/suite.dart';
|
| import '../backend/test.dart';
|
| import 'load_suite.dart';
|
| +import 'runner_suite.dart';
|
|
|
| /// An [Engine] manages a run that encompasses multiple test suites.
|
| ///
|
| @@ -84,15 +84,15 @@ class Engine {
|
| /// A group of futures for each test suite.
|
| final _group = new FutureGroup();
|
|
|
| - /// A sink used to pass [Suite]s in to the engine to run.
|
| + /// A sink used to pass [RunnerSuite]s in to the engine to run.
|
| ///
|
| /// Suites may be added as quickly as they're available; the Engine will only
|
| /// run as many as necessary at a time based on its concurrency settings.
|
| ///
|
| /// Suites added to the sink will be closed by the engine based on its
|
| /// internal logic.
|
| - Sink<Suite> get suiteSink => new DelegatingSink(_suiteController.sink);
|
| - final _suiteController = new StreamController<Suite>();
|
| + Sink<RunnerSuite> get suiteSink => new DelegatingSink(_suiteController.sink);
|
| + final _suiteController = new StreamController<RunnerSuite>();
|
|
|
| /// All the currently-known tests that have run, are running, or will run.
|
| ///
|
| @@ -164,7 +164,7 @@ class Engine {
|
| /// [concurrency] controls how many suites are run at once. An engine
|
| /// constructed this way will automatically close its [suiteSink], meaning
|
| /// that no further suites may be provided.
|
| - factory Engine.withSuites(List<Suite> suites, {int concurrency}) {
|
| + factory Engine.withSuites(List<RunnerSuite> suites, {int concurrency}) {
|
| var engine = new Engine(concurrency: concurrency);
|
| for (var suite in suites) engine.suiteSink.add(suite);
|
| engine.suiteSink.close();
|
| @@ -253,7 +253,7 @@ class Engine {
|
| }
|
|
|
| /// Returns a dummy [LiveTest] for a test marked as "skip".
|
| - LiveTest _skippedTest(Suite suite, Test test) {
|
| + LiveTest _skippedTest(RunnerSuite suite, Test test) {
|
| var controller;
|
| controller = new LiveTestController(suite, test, () {
|
| controller.setState(const State(Status.running, Result.success));
|
| @@ -266,7 +266,7 @@ class Engine {
|
| /// Adds listeners for [suite].
|
| ///
|
| /// Load suites have specific logic apart from normal test suites.
|
| - Future<Suite> _addLoadSuite(LoadSuite suite) async {
|
| + Future<RunnerSuite> _addLoadSuite(LoadSuite suite) async {
|
| var liveTest = await suite.tests.single.load(suite);
|
|
|
| _activeLoadTests.add(liveTest);
|
|
|