|
|
@@ -41,21 +41,19 @@ func sender(queue chan []byte, secret string) {
|
|
|
if err := ws.WriteMessage(websocket.BinaryMessage, data); err != nil {
|
|
|
log.Println("connection lost")
|
|
|
|
|
|
- time.Sleep(1 * time.Second)
|
|
|
-
|
|
|
break
|
|
|
}
|
|
|
|
|
|
if _, _, err := ws.ReadMessage(); err != nil {
|
|
|
log.Println("connection lost")
|
|
|
|
|
|
- time.Sleep(1 * time.Second)
|
|
|
-
|
|
|
break
|
|
|
}
|
|
|
}
|
|
|
|
|
|
ws.Close()
|
|
|
+
|
|
|
+ time.Sleep(1 * time.Second)
|
|
|
}
|
|
|
}
|
|
|
|
