Method Write

websocket/websocket.go:126–138

(msg []byte)

}

func (h *Hub) Write(msg []byte) (int, error) {
	tmp := make([]byte, len(msg))
	copy(tmp, msg)

	select {
	case h.broadcast <- tmp:
		return len(tmp), nil
	case <-h.quit:
		return 0, fmt.Errorf("websocket hub is shutting down")
	default:
		return 0, fmt.Errorf("failed to broadcast over websocket")
	}
}

func (h *Hub) Start() error {
	h.mux.Lock()