anchor.diff:    }
     
     void KickListening(){
  -    _connection.senddummy().then(this._conn_handler);
  +    _connection._senddummy().then(this._conn_handler);
     }
     
     void sendobject(Object cmd){
  
positive.code:   _SubscriptionDispatcher(this._connection){}
    
    void _conn_handler(var data){
      _connection.senddummy().then(_conn_handler);
      int len= data.length;
      switch(data[0]){
        case "message":
  
negative.code:   PubSubCommand(Command command){
      _command=new  Command(command._connection);
      _sub_dispatcher = new _SubscriptionDispatcher(command._connection);
      //makes sure that there is no 
      //more data on socket to process
      command.send_nothing().then((_){
        _sub_dispatcher.KickListening();
        command._connection = new _WarrningPubSubInProgress(); 
      });
  