Function readWebSocketMessage

rest/changes_api.go:700–711

Helper function to read a complete message from a WebSocket

(ctx context.Context, conn *websocket.Conn)

// Helper function to read a complete message from a WebSocket
func readWebSocketMessage(ctx context.Context, conn *websocket.Conn) ([]byte, error) {

	var message []byte
	if err := websocket.Message.Receive(conn, &message); err != nil {
		if err != io.EOF {
			base.WarnfCtx(ctx, "Error reading initial websocket message: %v", err)
			return nil, err
		}
	}
	return message, nil

}