anchor.diff:  final Logger logger = new Logger('clean_sync.subscription');
   
   void handleData(List<Map> data, Subscription subscription) {
  -  logger.fine('handleData: ${data}');
  +  logger.fine('handleData for ${subscription.resourceName}: ${data}');
     var collection = subscription.collection;
     subscription.updateLock.value = true;
     collection.clear();
  
positive.code:       });
    }
  
    void restart([Map args = const {}]) {
      logger.info("Restarting ${this} with args: ${args}");
      this.args = args;
      if (!_started) {
        logger.fine("First restart of subscription");
        _start();
      } else {
        if (!_initialSync.isCompleted) _initialSync.completeError(new CanceledException());
        _initialSync = createInitialSync();
  
negative.code:         requestLock = false;
          if(collection == null)
            collection = _createNewCollection();
          _start(initialData: initialData);
        });
      }
    }
  