mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-14 02:07:59 -07:00
Commit properly
This commit is contained in:
@@ -2119,6 +2119,7 @@ func (s *Server) InProcessConn() (net.Conn, error) {
|
||||
pl, pr := net.Pipe()
|
||||
if !s.startGoRoutine(func() {
|
||||
s.createClient(pl)
|
||||
s.grWG.Done()
|
||||
}) {
|
||||
pl.Close()
|
||||
pr.Close()
|
||||
|
||||
Reference in New Issue
Block a user