Apr 7, 2021 · Apr 7, 2021 · Apr 7, 2021 · Apr 7, 2021
diff --git a/conn_notjs.go b/conn_notjs.go
 }

 func (c *Conn) ping(ctx context.Context, p string) error {
 pong := make(chan struct{})
 pong := make(chan struct{}, 1)

 c.activePingsMu.Lock()
 c.activePings[p] = pong
diff --git a/read.go b/read.go
 pong, ok := c.activePings[string(b)]
 c.activePingsMu.Unlock()
 if ok {
 close(pong)
 select {
 case pong <- struct{}{}:
 default:
 }
 }
 return nil
 }
Original file line number	Diff line number	Diff line change
Expand Up		@@ -189,7 +189,7 @@ func (c *Conn) Ping(ctx context.Context) error {
		}

		func (c *Conn) ping(ctx context.Context, p string) error {
		pong := make(chan struct{})
		pong := make(chan struct{}, 1)

		c.activePingsMu.Lock()
		c.activePings[p] = pong
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -271,7 +271,10 @@ func (c *Conn) handleControl(ctx context.Context, h header) (err error) {
		pong, ok := c.activePings[string(b)]
		c.activePingsMu.Unlock()
		if ok {
		close(pong)
		select {
		case pong <- struct{}{}:
		default:
		}
		}
		return nil
		}
Expand Down