code: func (h *httpStreamHandler) portForward(p *httpStreamPair) {
  	defer p.dataStream.Close()
  	defer p.errorStream.Close()
  
  	portString := p.dataStream.Headers().Get(api.PortHeader)
  	port, _ := strconv.ParseInt(portString, 10, 32)
  
  	klog.V(5).Infof("(conn=%p, request=%s) invoking forwarder.PortForward for port %s", h.conn, p.requestID, portString)
  	err := h.forwarder.PortForward(h.pod, h.uid, int32(port), p.dataStream)
  	klog.V(5).Infof("(conn=%p, request=%s) done invoking forwarder.PortForward for port %s", h.conn, p.requestID, portString)
  
  	if err != nil {
  		msg := fmt.Errorf("error forwarding port %d to pod %s, uid %v: %v", port, h.pod, h.uid, err)
  		utilruntime.HandleError(msg)
  		fmt.Fprint(p.errorStream, msg.Error())
  	}
  }
docs: // portForward invokes the httpStreamHandler's forwarder.PortForward
  // function for the given stream pair.