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:     } else {
        _logger.info("${test.result} ${test.description}\n");
      }
  
      testDriver.testFinished(test);
    }
  
    void onSummary(int passed, int failed, int errors,
  