callOnDisconnectHandlers runs the registered disconnect handlers.
()
| 653 | |
| 654 | // callOnDisconnectHandlers runs the registered disconnect handlers. |
| 655 | func (c *Client) callOnDisconnectHandlers() { |
| 656 | c.m.RLock() |
| 657 | defer c.m.RUnlock() |
| 658 | |
| 659 | for _, handler := range c.onDisconnectHandlers { |
| 660 | func() { |
| 661 | defer nopRecover() |
| 662 | handler() |
| 663 | }() |
| 664 | } |
| 665 | } |
| 666 | |
| 667 | // callOnTokenExpireHandlers calls registered functions when an error |
| 668 | // from remote kite is received that token used is expired. |
no test coverage detected