Add the ability to run test suites in parallel.

lib/src/runner/reporter/compact.dart

 // 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 test.runner.reporter.compact;
 
 import 'dart:async';
 import 'dart:io';
 
 import '../../backend/live_test.dart';
@@ skipping 33 matching lines @@
 
   /// A stopwatch that tracks the duration of the full run.
   final _stopwatch = new Stopwatch();
 
   /// The set of tests that have completed and been marked as passing.
   final _passed = new Set<LiveTest>();
 
   /// The set of tests that have completed and been marked as failing or error.
   final _failed = new Set<LiveTest>();
 
+  /// The set of tests that are still running.
+  final _active = new List<LiveTest>();
+
   /// Whether [close] has been called.
   bool _closed = false;
 
   /// The size of [_passed] last time a progress notification was printed.
   int _lastProgressPassed;
 
   /// The size of [_failed] last time a progress notification was printed.
   int _lastProgressFailed;
 
   /// The message printed for the last progress notification.
   String _lastProgressMessage;
 
   // Whether a newline has been printed since the last progress line.
   var _printedNewline = true;
 
   /// Creates a [ConsoleReporter] that will run all tests in [suites].
   ///
   /// If [color] is `true`, this will use terminal colors; if it's `false`, it
   /// won't.
-  CompactReporter(Iterable<Suite> suites, {bool color: true})
+  CompactReporter(Iterable<Suite> suites, {int concurrency, bool color: true})
       : _multiplePaths = suites.map((suite) => suite.path).toSet().length > 1,
         _multiplePlatforms =
             suites.map((suite) => suite.platform).toSet().length > 1,
-        _engine = new Engine(suites),
+        _engine = new Engine(suites, concurrency: concurrency),
         _green = color ? '\u001b[32m' : '',
         _red = color ? '\u001b[31m' : '',
         _noColor = color ? '\u001b[0m' : '' {
     _engine.onTestStarted.listen((liveTest) {
-      _progressLine(_description(liveTest));
+      if (_active.isEmpty) _progressLine(_description(liveTest));
+      _active.add(liveTest);
       _printedNewline = false;
 
       liveTest.onStateChange.listen((state) {
         if (state.status != Status.complete) return;
+        _active.remove(liveTest);
         if (state.result == Result.success) {
           _passed.add(liveTest);
         } else {
           _passed.remove(liveTest);
           _failed.add(liveTest);
         }
-        _progressLine(_description(liveTest));
+
+        // Always display the name of the oldest active test, unless testing is
+        // finished in which case display the last test to complete.
+        if (_active.isEmpty) {
+          _progressLine(_description(liveTest));
+        } else {
+          _progressLine(_description(_active.first));
+        }
+
         _printedNewline = false;
       });
 
       liveTest.onError.listen((error) {
         if (liveTest.state.status != Status.complete) return;
 
         _progressLine(_description(liveTest));
         if (!_printedNewline) print('');
         _printedNewline = true;
 
@@ skipping 122 matching lines @@
       name = "${liveTest.suite.path}: $name";
     }
 
     if (_multiplePlatforms && liveTest.suite.platform != null) {
       name = "[${liveTest.suite.platform}] $name";
     }
 
     return name;
   }
 }