func()

in stream_proxy.go [30:35]


func (p *StreamProxy) proxy(to, from io.ReadWriter) {
	_, err := io.Copy(to, from)
	if err != nil {
		p.StopCh <- fmt.Errorf("failed to pipe stream: %v", err)
	}
}