code: func (c *Client) callOnConnectHandlers() {
  	c.m.RLock()
  	defer c.m.RUnlock()
  
  	for _, handler := range c.onConnectHandlers {
  		func() {
  			defer nopRecover()
  			handler()
  		}()
  	}
  }
docs: // callOnConnectHandlers runs the registered connect handlers.