ing

client.go

@@ -14,6 +14,7 @@ type Client interface {
 	ID() string
 	Conn() *websocket.Conn
 	Path() string
+	run()
 }
 
 type client struct {
@@ -34,8 +35,6 @@ func NewClient(id string, path string, o *ClientOptions, conn *websocket.Conn) C
 		messageType: websocket.TextMessage,
 	}
 
-	go c.run()
-
 	return c
 }
 

server.go

@@ -80,6 +80,8 @@ func (s *server) onConnection(ctx *fasthttp.RequestCtx) {
 		s._cMtx.Unlock()
 
 		s._option.OnConnection(c)
+
+		c.run()
 	})
 }