code: func (pf *PortForwarder) ForwardPorts() error {
  	defer pf.Close()
  
  	var err error
  	pf.streamConn, _, err = pf.dialer.Dial(PortForwardProtocolV1Name)
  	if err != nil {
  		return fmt.Errorf("error upgrading connection: %s", err)
  	}
  	defer pf.streamConn.Close()
  
  	return pf.forward()
  }
docs: // ForwardPorts formats and executes a port forwarding request. The connection will remain
  // open until stopChan is closed.