func()

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
}