anchor.diff:       */
       int _handlePublish(data) {
         MqttMessagePublish m = new MqttMessagePublish.decode(data, debugMessage);     
  +      if (m.len > data.length) {
  +        // Not enough data yet 
  +        return 0;
  +      }
         
         // QOS_1 and QOS_2 messages need to be acked
         if (m.QoS > 0) {   
  
positive.code:     */
     
     void _processData(data) {
       var remData = data;
       
       do {
       remData = _processMqttMessage(remData);
       } while (remData != null);     
     }
     
     /**
  
negative.code:   Map<int, Completer>  _messagesToCompleteMap;
    final String _userName;
    final String _password;
    var _remData;
    
    var _liveTimer;
    
  