@@ 214,22 214,4 @@ func (h *GoquiturHandler) serveOneWS(ws
Payload: payload,
})
}
-
-func notifyConn(conn *websocket.Conn, msg interface{}) error {
- log.Printf("notifying %v with %+v", conn, msg)
- return websocket.JSON.Send(conn, msg)
-}
-
-func (h *GoquiturHandler) notifyConns(path string, msg interface{}) {
- conns, ok := h.subs[path]
- if ok {
- for _, conn := range conns {
- go func(conn *websocket.Conn) {
- if err := notifyConn(conn, msg); err != nil {
- log.Println("Error while notifying a connection:", err)
- }
- }(conn)
- }
- }
-}
*/