Make handleStreamingMessage unexported

- change for loop semantics in (*StreamingConnectionManager).Run

Signed-off-by: Michael Stergianis <michaelstergianis@gmail.com>

internal/api/streaming_connection_manager.go

@@ -96,11 +96,10 @@ func (m *StreamingConnectionManager) Clients() []StreamingClient {
 
 // Run runs the manager. It manages multiple websocket clients.
 func (m *StreamingConnectionManager) Run(ctx context.Context) {
-	done := false
-	for !done {
+	for {
 		select {
 		case <-ctx.Done():
-			done = true
+			return
 		case meta := <-m.register:
 			m.clients[meta.client] = meta.cancelFunc
 		case client := <-m.unregister:

internal/api/websocket_client.go

@@ -174,15 +174,15 @@ func (c *WebsocketClient) readPump() {
 			continue
 		}
 
-		if err := HandleStreamingMessage(c, request); err != nil {
+		if err := handleStreamingMessage(c, request); err != nil {
 			c.logger.WithErr(err).Errorf("Handle websocket message")
 		}
 	}
 
 	close(c.stopCh)
 }
 
-func HandleStreamingMessage(client StreamingClient, request StreamRequest) error {
+func handleStreamingMessage(client StreamingClient, request StreamRequest) error {
 	handlers, ok := client.Handlers()[request.Type]
 	if !ok {
 		return handleUnknownRequest(client, request)