Method kick

internal/carrier/client.go:1319–1347

kick broadcasts to all idle poll workers. Safe to call from any goroutine. When adaptive coalescing is enabled (coalesceStep > 0) kicks within a burst are collapsed into a single delayed wake: the first kick arms a step-ms timer and records a hard deadline (now + coalesceMax); subsequent kicks rese

()

// stream of arrivals does not delay the wake past coalesceMax. When step
// is 0 the wake fires immediately as before.
func (c *Client) kick() {
	if c.coalesceStep <= 0 {
		c.wake.Broadcast()
		return
	}

	c.coalesceMu.Lock()
	defer c.coalesceMu.Unlock()

	now := time.Now()
	if c.coalesceTimer == nil {
		// First kick of a burst: set hard deadline and arm the step timer.
		c.coalesceDeadline = now.Add(c.coalesceMax)
		c.coalesceTimer = time.AfterFunc(c.coalesceStep, c.fireCoalesceWake)
		return
	}

	// Subsequent kick: extend the step timer, but never past the hard cap.
	nextFire := now.Add(c.coalesceStep)
	if nextFire.After(c.coalesceDeadline) {
		nextFire = c.coalesceDeadline
	}
	wait := nextFire.Sub(now)
	if wait <= 0 {
		// Already at or past the hard deadline — let the existing timer fire.
		return
	}
	c.coalesceTimer.Reset(wait)
}

// fireCoalesceWake clears the timer and broadcasts the wake. Called from
// the time.AfterFunc goroutine when the coalesce window closes.