fix bug

Allenxuxu · Dec 12, 2019 · 9d9d1c0 · 9d9d1c0
1 parent a71b547
commit 9d9d1c0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/server.go b/server.go
@@ -97,9 +97,9 @@ func (s *Server) handleNewConnection(fd int, sa *unix.Sockaddr) {
 
 	c := connection.New(fd, loop, sa, s.opts.Protocol, s.callback.OnMessage, s.callback.OnClose)
 
-	_ = loop.AddSocketAndEnableRead(fd, c)
-
 	s.callback.OnConnect(c)
+
+	_ = loop.AddSocketAndEnableRead(fd, c)
 }
 
 // Start 启动 Server