anchor.diff: -
   part of redis;
   
   //it used to delete subscription
  
positive.code:     });
    }
    
    Subscription subscribe(List<String> s){
      return _sub.subscribe(s);
    }
    
    Subscription psubscribe(List<String> s){
      return _sub.psubscribe(s);
    }
    
    void unsubscribe(List<String> s){
      List cmd = ["UNSUBSCRIBE"];
      cmd.add(s);
      _sub.sendobject(cmd);
    }
  
    void punsubscribe(List<String> s){
      List cmd = ["PUNSUBSCRIBE"];
      cmd.addAll(s);
      _sub.sendobject(cmd);
    }
    
  } 
  
  class _SubscriptionDispatcher{
    Subscription _sub = new Subscription();
    Subscription _psub = new Subscription();
    RedisConnection _connection;
    
    _SubscriptionDispatcher(this._connection){}
  
negative.code:         _sub._trie.send(data[1],data[2]);
          break;
        case "pmessage":
          _sub._trie.send(data[2],data[3]);
          break;
      }
    }
    
    void KickListening(){
      _connection.senddummy().then(this._conn_handler);
    }
    
    void sendobject(Object cmd){
  