anchor.diff:        }
       } else {
         if(_activeConsumer == null) {
  -        _activeConsumer = _makeRedisConsumer(current++);
  +        _activeConsumer = _makeRedisConsumer(data[current++]);
         }
         if(current < end) {
           current = _activeConsumer.consume(data, current, end);
  
positive.code: 
    void handleDone(EventSink<RedisReply> output) {
  
      print('Handling done');
      if (_currentReply != null) {
        var error = new UnexpectedRedisClosureError("Some data has already been sent but was not complete.");
        // Apparently some data has already been sent, but the stream is done.
  
negative.code:   void handleData(List<int> data, EventSink<RedisReply> output) {
      // I'm not entirely sure this is necessary, but better be safe.
      if (data.length == 0) return;
  
      final int end = data.length;
      var i = 0;
  