anchor.diff:    void _pipeStandardStreamsToConsole(
       Process process, {
       void startTimeoutTimer(),
  -    void storeObservatoryPort(int port)
  +    void storeObservatoryPort(int port),
     }) {
       for (Stream<List<int>> stream in
           <Stream<List<int>>>[process.stderr, process.stdout]) {
  
positive.code: typedef Future<Null> _Finalizer();
  
  class FlutterPlatform extends PlatformPlugin {
    FlutterPlatform({ this.shellPath, this.collector }) {
      assert(shellPath != null);
    }
  
    final String shellPath;
    final CoverageCollector collector;
  
    // Each time loadChannel() is called, we spin up a local WebSocket server,
    // then spin up the engine in a subprocess. We pass the engine a Dart file
  
negative.code:       localController.stream,
        remoteSink,
      );
      _startTest(testPath, localChannel, ourTestCount).whenComplete(() {
        testCompleteCompleter.complete();
      });
      return remoteChannel;
    }
  
    Future<Null> _startTest(String testPath, StreamChannel<dynamic> controller, int ourTestCount) async {
      printTrace('test $ourTestCount: starting test $testPath');
  
      final List<_Finalizer> finalizers = <_Finalizer>[];
  