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) } }