anchor.diff:          .catchError(_onSocketError);
   
     }
  -  
  +
     Future auth(String _password) {
       this.password = _password;
       return sendCommand(RedisCommand.AUTH, [ _password ]).receive();
  
positive.code:         throw new RedisClientException("The returned reply was not of type BulkReply but ${reply.runtimeType}.${error}");
        }
        return reply.string;
      }); 
    }
  
    /**
  
negative.code:   /// Redis database
    int db;
  
  
  
    void handleDone(EventSink<RedisReply> output);
  
    void handleError(Object error, StackTrace stackTrace, EventSink<RedisReply> sink);
  
    void handleData(List<int> data, EventSink<RedisReply> output);
  
    Future auth(String password);
  
    /// Closes the connection.
    Future close();
  
  