anchor.diff:    }
   
     void _start() {
  +    _started = true;
       logger.info("${this} starting");
       _errorStreamController.stream.listen((error){
         if(!error.toString().contains("__TEST__")) {
  
positive.code:   Future setupDataRequesting() {
      // request initial data; this is also called when restarting subscription
      logger.info("Setting up data requesting for ${this}");
      return _connection.send(_createDataRequest).then((response) {
        if (_initialSync.isCompleted) {
          return;
        }
        if (response['error'] != null) {
  
negative.code:     });
      setupConnectionRecovery();
      setupListeners();
      setupDataRequesting();
    }
  
  
  