code: func (h *portForwardProxy) portForward(p *httpStreamPair) {
  	defer p.dataStream.Close()
  	defer p.errorStream.Close()
  
  	portString := p.dataStream.Headers().Get(PortHeader)
  	port, _ := strconv.ParseInt(portString, 10, 32)
  
  	h.Debugf("Forwrarding port %v -> %v.", p.requestID, portString)
  	err := h.forwardStreamPair(p, port)
  	h.Debugf("Completed forwrarding port %v -> %v.", p.requestID, portString)
  
  	if err != nil {
  		msg := fmt.Errorf("error forwarding port %d to pod %s: %v", port, h.podName, err)
  		fmt.Fprint(p.errorStream, msg.Error())
  	}
  }
docs: // portForward invokes the portForwardProxy's forwarder.PortForward
  // function for the given stream pair.