Function WithReaperStop

agent/reaper/reaper.go:50–54

WithReaperStop sets a channel that, when closed, stops the reaper goroutine. Callers that invoke ForkReap more than once in the same process (e.g. tests) should use this to prevent goroutine accumulation.

(ch chan struct{})

// same process (e.g. tests) should use this to prevent goroutine
// accumulation.
func WithReaperStop(ch chan struct{}) Option {
	return func(o *options) {
		o.ReaperStop = ch
	}
}

// WithReaperStopped sets a channel that is closed after the
// reaper goroutine has fully exited.