tiny bug fix

This commit is contained in:
hdt3213
2022-04-03 19:22:18 +08:00
parent d1c8bbcae4
commit e2a1bbbe7d
2 changed files with 2 additions and 0 deletions

View File

@@ -57,6 +57,7 @@ func (h *Handler) Handle(ctx context.Context, conn net.Conn) {
if h.closing.Get() { if h.closing.Get() {
// closing handler refuse new connection // closing handler refuse new connection
_ = conn.Close() _ = conn.Close()
return
} }
client := connection.NewConn(conn) client := connection.NewConn(conn)

View File

@@ -45,6 +45,7 @@ func (h *EchoHandler) Handle(ctx context.Context, conn net.Conn) {
if h.closing.Get() { if h.closing.Get() {
// closing handler refuse new connection // closing handler refuse new connection
_ = conn.Close() _ = conn.Close()
return
} }
client := &EchoClient{ client := &EchoClient{