anchor.diff:    }
   }
   
  -
  -///
  -/// 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);
  - }
  -}
  -
  -
  
positive.code:     isSettingUp = false;
  
      await server.kill();
      _onErrors.add(null);
      _logger.severe("Analysis server has crashed. $event");
      return;
    }
  
negative.code:   await analysisComplete.first;
    await sendCompletionGetSuggestions(path, offset);
  
    return completionResults.handleError(
        (error) => throw "Completion failed").first;
  }
  
  Future<Map> completeSyncy(String src, int offset) async =>
  