func()

in websocket_proxy.go [35:48]


func (p *WebSocketProxy) proxy(to, from Connection, toAddr, fromAddr string) {
	for {
		messageType, data, err := from.ReadMessage()
		if err != nil {
			p.StopCh <- fmt.Errorf("reading from %s: %s", fromAddr, err)
			break
		}

		if err := to.WriteMessage(messageType, data); err != nil {
			p.StopCh <- fmt.Errorf("writing to %s: %s", toAddr, err)
			break
		}
	}
}