code: func (h *websocketStreamHandler) run() {
  	wg := sync.WaitGroup{}
  	wg.Add(len(h.streamPairs))
  
  	for _, pair := range h.streamPairs {
  		p := pair
  		go func() {
  			defer wg.Done()
  			h.portForward(p)
  		}()
  	}
  
  	wg.Wait()
  }
docs: // run invokes the websocketStreamHandler's forwarder.PortForward
  // function for the given stream pair.