fix(onmessage): trigger

Author: hongcha98

client.go

@@ -76,13 +76,15 @@ func (c *Client) readPump() {
 			c.Err = err
 			break
 		}
-		c.worker.broadcast <- Message{
+		msg := Message{
 			Name: c.Name,
 			Room: c.Room,
 			Code: code,
 			Data: data,
 			conn: c.conn,
 		}
+		c.worker.server.onMessage(&msg)
+		c.worker.broadcast <- msg
 	}
 }
 

worker.go

@@ -70,7 +70,6 @@ func (w *worker) run(ctx context.Context) {
 				return
 			}
 		case message := <-w.broadcast:
-			w.server.onMessage(&message)
 			for client := range w.clients {
 				if w.server.config.Local || message.conn != client.conn {
 					select {