- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for NextBackOff (0.11 sec)
-
pkg/adsc/delta.go
c.mutex.RLock() if c.closed { c.mutex.RUnlock() return } c.mutex.RUnlock() err := c.Run(context.Background()) if err != nil { time.AfterFunc(c.cfg.BackoffPolicy.NextBackOff(), c.reconnect) } else if c.cfg.BackoffPolicy != nil { // We connected, so reset the backoff c.cfg.BackoffPolicy.Reset() } } type Option func(c *Client)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 09:32:41 UTC 2024 - 20.4K bytes - Viewed (0) -
pkg/adsc/adsc.go
a.mutex.RLock() if a.closed { a.mutex.RUnlock() return } a.mutex.RUnlock() err := a.Run() if err != nil { // TODO: fix reconnect time.AfterFunc(a.cfg.BackoffPolicy.NextBackOff(), a.reconnect) } } func (a *ADSC) handleRecv() { // We connected, so reset the backoff if a.cfg.BackoffPolicy != nil { a.cfg.BackoffPolicy.Reset() } for { var err error
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 05 22:18:49 UTC 2024 - 35K bytes - Viewed (0)