code: @Override
    public boolean accept(HeadersAmp headers, List<Object> values,
                          long sequence, boolean isComplete)
    {
      if (isCancelled()) {
        sendCancel();
        return true;
      }
      
      synchronized (this) {
        if (values.size() > 0) {
          _count++;
        }
        
        if (isComplete) {
          _sequenceComplete = sequence;
        }
        
        ResultStream result = (ResultStream) _result;
  
        for (Object value : values) {
          result.accept(value);
        }
  
        if (_sequenceComplete >= 0 && _sequenceComplete <= _count) {
          result.ok();
          return true;
        }
        
        result.flush();
        return false;
      }
    }
docs: /*
  public int getCredit()
  {
  return _result.getCredit();
  }