(c *Client)
| 331 | } |
| 332 | |
| 333 | func (k *Kite) callOnConnectHandlers(c *Client) { |
| 334 | k.handlersMu.RLock() |
| 335 | defer k.handlersMu.RUnlock() |
| 336 | |
| 337 | for _, handler := range k.onConnectHandlers { |
| 338 | func() { |
| 339 | defer nopRecover() |
| 340 | handler(c) |
| 341 | }() |
| 342 | } |
| 343 | } |
| 344 | |
| 345 | func (k *Kite) callOnFirstRequestHandlers(c *Client) { |
| 346 | k.handlersMu.RLock() |
no test coverage detected