anchor.diff:      isSettingUp = false;
   
       await server.kill();
  -    _onErrors.add(null);
  +    _onCompletionResults.addError(null);
       _logger.severe("Analysis server has crashed. $event");
       return;
     }
  
positive.code:   }
  }
  
  
  ///
  /// Class to support merging multiple streams together into one so that
  /// the first item can be extracted from either, this is used for blocking
  /// on either a result or an error.
  ///
  class MergeStream {
    final StreamController controller = new StreamController();
  
    Stream get stream => controller.stream;
  
    void add(Stream stream) {
      stream.listen(controller.add);
   }
  }
  
  
  
negative.code:   _onCompletionResults = new StreamController(sync: true);
    completionResults = _onCompletionResults.stream.asBroadcastStream();
  
    _logger.fine("Server about to start");
  
    // Warm up target.
  