in stream_proxy.go [22:28]
func (p *StreamProxy) Serve(client io.ReadWriter, server io.ReadWriter) error { go p.proxy(client, server) go p.proxy(server, client) err := <-p.StopCh return err }