Dial connects to the remote Kite. If it can't connect, it retries indefinitely. It returns a channel to check if it's connected or not.
()
| 254 | // Dial connects to the remote Kite. If it can't connect, it retries |
| 255 | // indefinitely. It returns a channel to check if it's connected or not. |
| 256 | func (c *Client) DialForever() (connected chan bool, err error) { |
| 257 | c.Reconnect = true |
| 258 | connected = make(chan bool, 1) // This will be closed on first connection. |
| 259 | go c.dialForever(connected) |
| 260 | return |
| 261 | } |
| 262 | |
| 263 | func (c *Client) updateAuth(reg *protocol.RegisterResult) { |
| 264 | c.authMu.Lock() |
no test coverage detected