hub: added buffer size for the broadcasting channel, added closing of connection with the client in case of sending channel buffer overflow

Author: Lapp

README.md

@@ -1,5 +1,5 @@
 # Чат на вебсокетах
-[![Release](https://img.shields.io/badge/release-v1.0.0-blue)](https://github.com/Lapp-coder/go-pocket-sdk/releases)
+[![Release](https://img.shields.io/badge/release-v1.0.1-blue)](https://github.com/Lapp-coder/go-pocket-sdk/releases)
 
 ### Для запуска сервера используйте следующую команду
 ```make docker-build && docker run --name=chat -e CHAT_HOST=<host> -e CHAT_PORT=<port> -p <port>>:<port> --rm websocket-chat```

hub.go

@@ -11,7 +11,7 @@ type hub struct {
 func newHub() *hub {
 	return &hub{
 		connections: make(map[*connection]struct{}),
-		broadcast:   make(chan []byte),
+		broadcast:   make(chan []byte, 10000),
 		register:    make(chan *connection),
 		unregister:  make(chan *connection),
 	}
@@ -30,7 +30,12 @@ func (h *hub) listen() {
 			}
 		case message := <-h.broadcast:
 			for conn := range h.connections {
-				conn.send <- message
+				select {
+				case conn.send <- message:
+				default:
+					delete(h.connections, conn)
+					close(conn.send)
+				}
 			}
 		}
 	}