diff --git a/src/croc/recipient.go b/src/croc/recipient.go index 63bdf68..fe632ac 100644 --- a/src/croc/recipient.go +++ b/src/croc/recipient.go @@ -426,6 +426,9 @@ func (cr *Croc) receive(forceSend int, serverAddress string, tcpPorts []string, for { // read from websockets websocketMessageData := <-websocketMessages + if bytes.HasPrefix(websocketMessageData.message, []byte("error")) { + return fmt.Errorf("%s", websocketMessageData.message) + } if websocketMessageData.messageType != websocket.BinaryMessage { continue }