diff --git a/transport/internet/tcp/hub.go b/transport/internet/tcp/hub.go index 8075936a..00c1c06b 100644 --- a/transport/internet/tcp/hub.go +++ b/transport/internet/tcp/hub.go @@ -153,7 +153,7 @@ func (v *TCPListener) Close() error { close(v.awaitingConns) for connErr := range v.awaitingConns { if connErr.conn != nil { - go connErr.conn.Close() + connErr.conn.Close() } } return nil diff --git a/transport/internet/websocket/hub.go b/transport/internet/websocket/hub.go index eba47c53..e0365e3d 100644 --- a/transport/internet/websocket/hub.go +++ b/transport/internet/websocket/hub.go @@ -192,7 +192,7 @@ func (v *WSListener) Close() error { close(v.awaitingConns) for connErr := range v.awaitingConns { if connErr.conn != nil { - go connErr.conn.Close() + connErr.conn.Close() } } return nil