anchor.diff:        current = takeTo;
       }
   
  -    if(current < end) {
  +    if(current < end && !done) {
         current = consume(data, current, end);
       }
   
  
positive.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;
      //print("Got ${data.length} => $data");
  
      final int end = data.length;
      var i = 0;
  
negative.code:     assert(start < end);
  
      int current = start;
      if(_lengthRequired == null) {
        current = _lineConsumer.consume(data, current, end);
        if(_lineConsumer.done) {
          final specifiedLength =
  