code: func DefaultConsumeRequest(request rest.ResponseWrapper, out io.Writer) error {
  	readCloser, err := request.Stream()
  	if err != nil {
  		return err
  	}
  	defer readCloser.Close()
  
  	r := bufio.NewReader(readCloser)
  	for {
  		bytes, err := r.ReadBytes('\n')
  		if _, err := out.Write(bytes); err != nil {
  			return err
  		}
  
  		if err != nil {
  			if err != io.EOF {
  				return err
  			}
  			return nil
  		}
  	}
  }
docs: // DefaultConsumeRequest reads the data from request and writes into
  // the out writer. It buffers data from requests until the newline or io.EOF
  // occurs in the data, so it doesn't interleave logs sub-line
  // when running concurrently.
  //
  // A successful read returns err == nil, not err == io.EOF.
  // Because the function is defined to read from request until io.EOF, it does
  // not treat an io.EOF as an error to be reported.