Start runs the background acquire/wake loop that picks up pending chats and processes them. Callers that want a passive server (e.g. tests) can skip this call; heartbeat, stream janitor, and stale recovery still run.
()
| 4344 | // server (e.g. tests) can skip this call; heartbeat, stream |
| 4345 | // janitor, and stale recovery still run. |
| 4346 | func (p *Server) Start() *Server { |
| 4347 | p.wg.Go(func() { p.acquireLoop(p.ctx) }) |
| 4348 | return p |
| 4349 | } |
| 4350 | |
| 4351 | func (p *Server) acquireLoop(ctx context.Context) { |
| 4352 | acquireTicker := p.clock.NewTicker( |
no test coverage detected