anchor.diff:  class TestDriver {
     final JobManager _jobManager;
     StreamSubscription _logListener;
  +  StreamController<unittest.TestCase> _onTestFinished =
  +      new StreamController.broadcast();
   
     Function _defineTestsFn;
     Element _testDiv;
  
positive.code:     _jobManager.schedule(job);
  
      return _testCompleter.future;
    }
  
    void _connectToListener() {
  
negative.code:       : super("Running tests…", completer);
  
    Future<Job> run(ProgressMonitor monitor) {
      monitor.start(
          name,
          maxWork: unittest.testCases.length,
          format: ProgressFormat.N_OUT_OF_M);
      testDriver.onTestFinished.listen((_) => monitor.worked(1));
  
      unittest.runTests();
  
  